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")