From 7cc44522faf6ce7666a0be323dd3d8ff268a472b Mon Sep 17 00:00:00 2001 From: Lumither Tao Date: Fri, 7 Mar 2025 23:52:44 -0800 Subject: [PATCH] feat(backend::scheduler) fix runtime issue --- backend/server/src/scheduler/runner.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/backend/server/src/scheduler/runner.rs b/backend/server/src/scheduler/runner.rs index 6aca062..b3ca00b 100644 --- a/backend/server/src/scheduler/runner.rs +++ b/backend/server/src/scheduler/runner.rs @@ -44,7 +44,6 @@ impl TaskEntity { self.status.sleeper.read().unwrap().start(); if self.status.expected_running.load(Ordering::SeqCst) { self.func.call().await; - if let Some(next_execution) = self.func.get_next_execution() { *(self.status.sleeper.write().unwrap()) = next_execution.into(); } else { @@ -104,7 +103,9 @@ impl Runner { tokio::spawn({ let entity_clone = entity.clone(); async move { entity_clone.run_blocking().await } - }); + }) + .await + .expect("tokio runtime error"); } }