diff --git a/index-scheduler/src/lib.rs b/index-scheduler/src/lib.rs index 220d484c9..612a31337 100644 --- a/index-scheduler/src/lib.rs +++ b/index-scheduler/src/lib.rs @@ -348,7 +348,8 @@ impl IndexScheduler { } } - self.notify(); + // notify the scheduler loop to execute a new tick + self.wake_up.signal(); Ok(task.as_task_view()) } @@ -438,11 +439,6 @@ impl IndexScheduler { Ok(processed_tasks) } - - /// Notify the scheduler there is or may be work to do. - pub fn notify(&self) { - self.wake_up.signal() - } } #[cfg(test)]