From 7e8e1e1f078f3d4d20f548667109658d7ed0c3f7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johannes=20B=C3=BClow?= Date: Fri, 15 Aug 2025 19:17:10 +0200 Subject: [PATCH] processing jobs bugfixes --- server/internal/database/processingJob.go | 1 + server/internal/database/queries-processing_jobs.sql | 9 +++++---- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/server/internal/database/processingJob.go b/server/internal/database/processingJob.go index 3154299..4f51803 100644 --- a/server/internal/database/processingJob.go +++ b/server/internal/database/processingJob.go @@ -50,6 +50,7 @@ func FailProcessingJob(jobid int64, jobErr error) error { var params sqlc.FailProcessingJobParams params.ID = jobid params.Error.String = jobErr.Error() + params.Error.Valid = true err := query.FailProcessingJob(context.Background(), params) if err != nil { slog.Error("Unable to mark processing job as failed", "job-id", jobid, "error", err) diff --git a/server/internal/database/queries-processing_jobs.sql b/server/internal/database/queries-processing_jobs.sql index a10fd9a..99f7170 100644 --- a/server/internal/database/queries-processing_jobs.sql +++ b/server/internal/database/queries-processing_jobs.sql @@ -16,10 +16,6 @@ SET completed = NOW(), status = 'completed' WHERE id = $1; --- name: GetJobsForFile :many -SELECT * FROM processing_jobs -WHERE file_id = $1; - -- name: GetJob :one SELECT * FROM processing_jobs WHERE id = $1 @@ -34,3 +30,8 @@ WHERE id = $2; -- name: GetAllJobs :many SELECT * FROM processing_jobs; + +-- name: GetJobsForFile :many +SELECT * FROM processing_jobs +WHERE file_id = $1 +ORDER BY created DESC;