diff --git a/backend/src/main.rs b/backend/src/main.rs index af4781f6f0..187f04c8e1 100644 --- a/backend/src/main.rs +++ b/backend/src/main.rs @@ -802,16 +802,9 @@ Windmill Community Edition {GIT_VERSION} #[cfg(not(all(feature = "tantivy", feature = "parquet")))] let log_indexer_f = async { Ok(()) as anyhow::Result<()> }; - let worker_internal_server_killpill_rx = killpill_rx.resubscribe(); let server_f = async { if !is_agent { if let Some(db) = conn.as_sql() { - if worker_mode { - init_worker_internal_server_inline_utils( - worker_internal_server_killpill_rx, - base_internal_url.clone(), - )?; - } windmill_api::run_server( db.clone(), index_reader, @@ -842,6 +835,11 @@ Windmill Community Edition {GIT_VERSION} if !killpill_rx.try_recv().is_ok() { let base_internal_url = base_internal_rx.await?; if worker_mode { + let worker_internal_server_killpill_rx = killpill_rx.resubscribe(); + init_worker_internal_server_inline_utils( + worker_internal_server_killpill_rx, + base_internal_url.clone(), + )?; let mut workers = vec![]; for i in 0..num_workers {