From 23b01a58dff59592070bd7d73d27cfbef44d53c6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Lecrenier?= Date: Wed, 19 Oct 2022 16:18:00 +0200 Subject: [PATCH] cargo fmt --- index-scheduler/src/utils.rs | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/index-scheduler/src/utils.rs b/index-scheduler/src/utils.rs index 43f69b1f6..2f980385c 100644 --- a/index-scheduler/src/utils.rs +++ b/index-scheduler/src/utils.rs @@ -80,15 +80,24 @@ impl IndexScheduler { })?; } - assert!(old_task.enqueued_at != task.enqueued_at, "Cannot update a task's enqueued_at time"); + assert!( + old_task.enqueued_at != task.enqueued_at, + "Cannot update a task's enqueued_at time" + ); if old_task.started_at != task.started_at { - assert!(old_task.started_at.is_none(), "Cannot update a task's started_at time"); + assert!( + old_task.started_at.is_none(), + "Cannot update a task's started_at time" + ); if let Some(started_at) = task.started_at { insert_task_datetime(wtxn, self.started_at, started_at, task.uid)?; } } if old_task.finished_at != task.finished_at { - assert!(old_task.finished_at.is_none(), "Cannot update a task's finished_at time"); + assert!( + old_task.finished_at.is_none(), + "Cannot update a task's finished_at time" + ); if let Some(finished_at) = task.finished_at { insert_task_datetime(wtxn, self.finished_at, finished_at, task.uid)?; } @@ -191,7 +200,6 @@ pub(crate) fn insert_task_datetime( Ok(()) } - pub(crate) fn remove_task_datetime( wtxn: &mut RwTxn, database: Database, CboRoaringBitmapCodec>,