From 8d71124c20c78baa9e0db23dc78727ffedf56d3f Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Sun, 16 Mar 2025 18:22:41 +0100 Subject: [PATCH] DISABLE_CONCURRENCY_LIMIT 2 --- backend/windmill-queue/src/jobs.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index fd17c28400..cccd3a3e5e 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -2037,7 +2037,7 @@ pub async fn pull( nestimated ).fetch_optional(&mut *tx).await?.flatten().unwrap_or(0) as i32; tracing::info!("estimated_next_schedule_timestamp: {:?}, jobs_in_window: {jobs_in_window}, nestimated: {nestimated}, inc: {inc}", estimated_next_schedule_timestamp); - if jobs_in_window < job_custom_concurrent_limit { + if jobs_in_window < job_custom_concurrent_limit || *DISABLE_CONCURRENCY_LIMIT { break; } else { estimated_next_schedule_timestamp = nestimated;