diff --git a/server/src/services/analytic_service/analytic_service.rs b/server/src/services/analytic_service/analytic_service.rs index bd5756a..032e558 100644 --- a/server/src/services/analytic_service/analytic_service.rs +++ b/server/src/services/analytic_service/analytic_service.rs @@ -114,14 +114,12 @@ impl AnalyticService { // TODO: make fn run_detection_runner(&mut self, from: u64) { - println!("run_detection_runner"); // TODO: handle case or make it impossible to run_detection_runner second time if self.analytic_unit_learning_status != LearningStatus::Ready { let task = DetectionRunnerTask { from }; - println!("add learning waiter"); self.learning_waiters.push(LearningWaiter::DetectionRunner(task)); return; } diff --git a/server/src/services/analytic_service/detection_runner.rs b/server/src/services/analytic_service/detection_runner.rs index a00a3b5..c77e4ce 100644 --- a/server/src/services/analytic_service/detection_runner.rs +++ b/server/src/services/analytic_service/detection_runner.rs @@ -27,7 +27,6 @@ impl DetectionRunner { pub fn run(&mut self, from: u64) { // TODO: get last detection timestamp from persistance // TODO: set last detection from "now" - println!("Run begn"); if self.running_handler.is_some() { self.running_handler.as_mut().unwrap().abort(); } @@ -40,9 +39,9 @@ impl DetectionRunner { // TODO: define window for detection // TODO: save last detection - + println!("detection runner started from {}", from); loop { - println!("runner detect"); + // TODO: run detection periodically sleep(Duration::from_secs(cfg.interval)).await; }