Set worker-id to None when marking a job as runnable after expired heartbeats

2024-01-04 10:29:37 -06:00 · 2024-01-04 10:29:37 -06:00 · 7d4f44a540
parent e4e5aad215
commit 7d4f44a540
1 changed files with 1 additions and 0 deletions
--- a/src/repo/postgres.rs
+++ b/src/repo/postgres.rs
@ -1167,6 +1167,7 @@ impl QueueRepo for PostgresRepo {
                .set((
                    heartbeat.eq(Option::<time::PrimitiveDateTime>::None),
                    status.eq(JobStatus::New),
+                    worker.eq(Option::<Uuid>::None),
                ))
                .execute(&mut conn)
                .with_metrics("pict-rs.postgres.queue.requeue")