parent
e05051f34d
commit
9298f4cccf
1 changed files with 1 additions and 1 deletions
|
@ -303,7 +303,7 @@ func queueOnHealth(ctx context.Context, taskID int) {
|
||||||
FROM tasks
|
FROM tasks
|
||||||
INNER JOIN files ON files.id = tasks.file_id
|
INNER JOIN files ON files.id = tasks.file_id
|
||||||
INNER JOIN libraries ON files.library_id = libraries.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)
|
Scan(&transcode_command_id, &file_id)
|
||||||
if err == pgx.ErrNoRows {
|
if err == pgx.ErrNoRows {
|
||||||
slog.DebugContext(ctx, "No need to queue Transcode", "task_id", taskID)
|
slog.DebugContext(ctx, "No need to queue Transcode", "task_id", taskID)
|
||||||
|
|
Loading…
Add table
Reference in a new issue