ensure last_heartbeat_at on dequeue

maxcountryman · Nov 10, 2024 · 01cb957 · 01cb957
1 parent ec634b4
commit 01cb957
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/...0ec74f97447850cebdebba1c0748059ce17e.json → ...dccb8d22d4591ba8920691213829c0a11622.json b/...0ec74f97447850cebdebba1c0748059ce17e.json → ...dccb8d22d4591ba8920691213829c0a11622.json
diff --git a/src/queue.rs b/src/queue.rs
@@ -645,7 +645,9 @@ impl<T: Task> Queue<T> {
             InProgressTask,
             r#"
             update underway.task
-            set state = $3, last_attempt_at = now()
+            set state = $3,
+                last_attempt_at = now(),
+                last_heartbeat_at = now()
             where id = (
                 select id
                 from underway.task