diff --git a/src/worker_runner.rs b/src/worker_runner.rs index 7516ae6..79a4503 100644 --- a/src/worker_runner.rs +++ b/src/worker_runner.rs @@ -62,7 +62,7 @@ async fn connect_and_run( server_url: &str, worker_name: &str, llm_config: &crate::LlmConfig, - svc_mgr: &ServiceManager, + svc_mgr: &Arc, shared_ws_tx: &SharedWsTx, comment_tx: &Arc>>>, ) -> anyhow::Result<()> { @@ -178,7 +178,7 @@ async fn connect_and_run( let (evt_tx, mut evt_rx) = mpsc::channel::(32); *comment_tx.lock().await = Some(evt_tx); - let svc = svc_mgr.clone(); + let svc = Arc::clone(svc_mgr); let wf_id = workflow_id.clone(); let pid = project_id.clone(); tokio::spawn(async move {