speatzle/morffix
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

Also Count Unkown Tasks as Assigned

Browse source
This commit is contained in:
Samuel Lorch 2024-07-06 03:08:58 +02:00
parent c37c26908d
commit a9d901da71
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/task.go
View file

@ -358,7 +358,7 @@ func assignQueuedTasks(ctx context.Context) error {
} }
if Workers[i].Connected { if Workers[i].Connected {
var count int var count int
err := db.QueryRow(ctx, "SELECT COUNT(*) FROM tasks WHERE worker_id = $1 AND (status = $2 OR status = $3 OR status = $4)", i, constants.TASK_STATUS_ASSIGNED, constants.TASK_STATUS_RUNNING, constants.TASK_STATUS_WAITING).Scan(&count) err := db.QueryRow(ctx, "SELECT COUNT(*) FROM tasks WHERE worker_id = $1 AND (status = $2 OR status = $3 OR status = $4 OR status = $5)", i, constants.TASK_STATUS_UNKNOWN, constants.TASK_STATUS_ASSIGNED, constants.TASK_STATUS_RUNNING, constants.TASK_STATUS_WAITING).Scan(&count)
if err != nil { if err != nil {
return fmt.Errorf("Error Querying Worker Task Count: %w", err) return fmt.Errorf("Error Querying Worker Task Count: %w", err)
} }