diff --git a/server/worker.go b/server/worker.go index 9668c45..858f25f 100644 --- a/server/worker.go +++ b/server/worker.go @@ -303,7 +303,7 @@ func queueOnHealth(ctx context.Context, taskID int) { FROM tasks INNER JOIN files ON files.id = tasks.file_id INNER JOIN libraries ON files.library_id = libraries.id - WHERE tasks.id = $1 AND libraries.health_ok_queue_transcode = t AND libraries.transcode_command_id IS NOT NULL`, taskID). + WHERE tasks.id = $1 AND libraries.health_ok_queue_transcode = true AND libraries.transcode_command_id IS NOT NULL`, taskID). Scan(&transcode_command_id, &file_id) if err == pgx.ErrNoRows { slog.DebugContext(ctx, "No need to queue Transcode", "task_id", taskID)