diff --git a/src/server/worker_task.rs b/src/server/worker_task.rs index 852f3ecc..ba83de60 100644 --- a/src/server/worker_task.rs +++ b/src/server/worker_task.rs @@ -473,8 +473,6 @@ impl WorkerTask { { println!("register worker thread"); - let (p, c) = oneshot::channel::<()>(); - let worker = WorkerTask::new(worker_type, worker_id, userid, to_stdout)?; let upid_str = worker.upid.to_string(); @@ -495,11 +493,8 @@ impl WorkerTask { }; worker.log_result(&result); - p.send(()).unwrap(); }); - tokio::spawn(c.map(|_| ())); - Ok(upid_str) }