From 7d4f44a5401c31bab62267d0c210a1f5b7e94f63 Mon Sep 17 00:00:00 2001 From: asonix Date: Thu, 4 Jan 2024 10:29:37 -0600 Subject: [PATCH] Set worker-id to None when marking a job as runnable after expired heartbeats --- src/repo/postgres.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/repo/postgres.rs b/src/repo/postgres.rs index ccb3aff..fa5a5ab 100644 --- a/src/repo/postgres.rs +++ b/src/repo/postgres.rs @@ -1167,6 +1167,7 @@ impl QueueRepo for PostgresRepo { .set(( heartbeat.eq(Option::::None), status.eq(JobStatus::New), + worker.eq(Option::::None), )) .execute(&mut conn) .with_metrics("pict-rs.postgres.queue.requeue")