provide queue name in dequeue update

While this is not technically required, since the CTE has already filtered with the name, it's nonetheless more clear regarding the intent and underlying data model at play.
maxcountryman · Nov 16, 2024 · d8dc087 · d8dc087
1 parent bf627cd
commit d8dc087
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 9 deletions.
diff --git a/...fbe76e5070e0f613ca500fc3a38df8f323a6.json → ...5f076c68ade8c96b4f5bbbbdfc83f5f60748.json b/...fbe76e5070e0f613ca500fc3a38df8f323a6.json → ...5f076c68ade8c96b4f5bbbbdfc83f5f60748.json
diff --git a/src/queue.rs b/src/queue.rs
@@ -694,15 +694,16 @@ impl<T: Task> Queue<T> {
                 last_attempt_at = now(),
                 last_heartbeat_at = now()
             from available_task
-            where t.id = available_task.id
+            where t.task_queue_name = $1
+              and t.id = available_task.id
             returning
                 t.id as "id: TaskId",
-                task_queue_name as "queue_name",
-                input,
-                timeout,
-                heartbeat,
-                retry_policy as "retry_policy: RetryPolicy",
-                concurrency_key
+                t.task_queue_name as "queue_name",
+                t.input,
+                t.timeout,
+                t.heartbeat,
+                t.retry_policy as "retry_policy: RetryPolicy",
+                t.concurrency_key
             "#,
             self.name,
             TaskState::Pending as TaskState,