fix: fix concurrent limit jobs non restarting

windmill-labs · Feb 10, 2025 · 4828a77 · 4828a77
1 parent ddf218a
commit 4828a77
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/...d6109d2a6633e62ce708bad8af1a9f8c3925.json → ...f0d370cf1ab4d41f68494a940951eaa52bc3.json b/...d6109d2a6633e62ce708bad8af1a9f8c3925.json → ...f0d370cf1ab4d41f68494a940951eaa52bc3.json
diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
@@ -2040,13 +2040,14 @@ pub async fn pull(
                 running = false,
                 started_at = null,
                 scheduled_for = $1
-            WHERE id = (SELECT id FROM ping)",
+            WHERE id = $2",
             estimated_next_schedule_timestamp,
             job_uuid,
         )
-        .fetch_all(&mut *tx)
+        .execute(&mut *tx)
         .await
         .map_err(|e| Error::internal_err(format!("Could not update and re-queue job {job_uuid}. The job will be marked as running but it is not running: {e:#}")))?;
+
         tx.commit().await?
     }
 }