From f2e22366535f00e26b4be7f11b35909f352006b1 Mon Sep 17 00:00:00 2001 From: speatzle Date: Fri, 11 Oct 2024 17:45:23 +0200 Subject: [PATCH] fix sql --- server/worker.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/worker.go b/server/worker.go index 858f25f..293594e 100644 --- a/server/worker.go +++ b/server/worker.go @@ -299,7 +299,7 @@ func updateWorkerTaskStatus(ctx context.Context) { func queueOnHealth(ctx context.Context, taskID int) { var transcode_command_id *int var file_id *int - err := db.QueryRow(ctx, `SELECT libraries.transcode_command_id, file.id + err := db.QueryRow(ctx, `SELECT libraries.transcode_command_id, files.id FROM tasks INNER JOIN files ON files.id = tasks.file_id INNER JOIN libraries ON files.library_id = libraries.id @@ -308,7 +308,7 @@ func queueOnHealth(ctx context.Context, taskID int) { if err == pgx.ErrNoRows { slog.DebugContext(ctx, "No need to queue Transcode", "task_id", taskID) } else if err != nil { - slog.ErrorContext(ctx, "Unable to Query if and how she should queue a Transcode on Health Check Success", "err", err) + slog.ErrorContext(ctx, "Unable to Query if and how we should queue a Transcode on Health Check Success", "err", err) return }