From 8f2606d79d8aa5bb79df036d0e8d673327010fb7 Mon Sep 17 00:00:00 2001 From: Bruno Casali Date: Wed, 27 Mar 2024 14:26:47 -0300 Subject: [PATCH] fixes typos --- index-scheduler/src/lib.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/index-scheduler/src/lib.rs b/index-scheduler/src/lib.rs index 46ed76649..59bfa1ecf 100644 --- a/index-scheduler/src/lib.rs +++ b/index-scheduler/src/lib.rs @@ -1301,8 +1301,8 @@ impl IndexScheduler { wtxn.commit().map_err(Error::HeedTransaction)?; - // Once the tasks are commited, we should delete all the update files associated ASAP to avoid leaking files in case of a restart - tracing::debug!("Deleting the upadate files"); + // Once the tasks are committed, we should delete all the update files associated ASAP to avoid leaking files in case of a restart + tracing::debug!("Deleting the update files"); //We take one read transaction **per thread**. Then, every thread is going to pull out new IDs from the roaring bitmap with the help of an atomic shared index into the bitmap let idx = AtomicU32::new(0); @@ -1332,7 +1332,7 @@ impl IndexScheduler { Ok(TickOutcome::TickAgain(processed_tasks)) } - /// Once the tasks changes have been commited we must send all the tasks that were updated to our webhook if there is one. + /// Once the tasks changes have been committed we must send all the tasks that were updated to our webhook if there is one. fn notify_webhook(&self, updated: &RoaringBitmap) -> Result<()> { if let Some(ref url) = self.webhook_url { struct TaskReader<'a, 'b> {