diff --git a/backend/src/main.rs b/backend/src/main.rs index e8f7548702..90758997cb 100644 --- a/backend/src/main.rs +++ b/backend/src/main.rs @@ -790,6 +790,10 @@ pub async fn run_workers 1 { + tracing::info!(worker = %worker_name, "starting worker {i}"); + } let f = windmill_worker::run_worker( &db1, diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index fd8d386ce8..4d60f8db6c 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -287,10 +287,14 @@ lazy_static::lazy_static! { pub static ref JOB_TOKEN: Option = std::env::var("JOB_TOKEN").ok(); - static ref SLEEP_QUEUE: u64 = std::env::var("SLEEP_QUEUE") + pub static ref SLEEP_QUEUE: u64 = std::env::var("SLEEP_QUEUE") .ok() .and_then(|x| x.parse::().ok()) - .unwrap_or(DEFAULT_SLEEP_QUEUE); + .unwrap_or(DEFAULT_SLEEP_QUEUE * std::env::var("NUM_WORKERS") + .ok() + .map(|x| x.parse().ok()) + .flatten() + .unwrap_or(2) / 2); pub static ref DISABLE_NUSER: bool = std::env::var("DISABLE_NUSER")