parent
9298f4cccf
commit
f2e2236653
1 changed files with 2 additions and 2 deletions
|
@ -299,7 +299,7 @@ func updateWorkerTaskStatus(ctx context.Context) {
|
||||||
func queueOnHealth(ctx context.Context, taskID int) {
|
func queueOnHealth(ctx context.Context, taskID int) {
|
||||||
var transcode_command_id *int
|
var transcode_command_id *int
|
||||||
var file_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
|
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
|
||||||
|
@ -308,7 +308,7 @@ func queueOnHealth(ctx context.Context, taskID int) {
|
||||||
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)
|
||||||
} else if err != nil {
|
} 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
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue