diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index 03d7426b2f..9509fa46e0 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -101,7 +101,7 @@ lazy_static::lazy_static! { ORDER BY scheduled_for, created_at FOR UPDATE SKIP LOCKED LIMIT 1 - ) LIMIT 1 + ) RETURNING *", format!(" AND ({})", ACCEPTED_TAGS.clone().into_iter().map(|x| format!("(tag = '{x}')")).join(" OR "))