diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index 4ae97fd18a..5b85adca53 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -761,7 +761,7 @@ pub async fn pull( concurrent_jobs_for_this_script.unwrap_or(-1) ); if concurrent_jobs_for_this_script.is_none() - || concurrent_jobs_for_this_script.unwrap() < i64::from(job_custom_concurrent_limit) + || concurrent_jobs_for_this_script.unwrap() <= i64::from(job_custom_concurrent_limit) { if *METRICS_ENABLED { QUEUE_PULL_COUNT.inc();