From 84244a74dfe918eaec61cedd35cec64624fa61e1 Mon Sep 17 00:00:00 2001 From: Mubelotix Date: Tue, 12 Aug 2025 16:44:28 +0200 Subject: [PATCH] Fix bug --- crates/index-scheduler/src/scheduler/process_batch.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/crates/index-scheduler/src/scheduler/process_batch.rs b/crates/index-scheduler/src/scheduler/process_batch.rs index cdda88617..0f83da7d4 100644 --- a/crates/index-scheduler/src/scheduler/process_batch.rs +++ b/crates/index-scheduler/src/scheduler/process_batch.rs @@ -562,7 +562,9 @@ impl IndexScheduler { current -= &to_remove; if current.is_empty() { - delete_range_start = Some(timestamp); + if delete_range_start.is_none() { + delete_range_start = Some(timestamp); + } } else { // We could close the deletion range but it's not necessary because the new value will get reinserted anyway to_put.insert(timestamp, current); @@ -608,7 +610,9 @@ impl IndexScheduler { current -= to_remove; if current.is_empty() { - delete_range_start = Some(timestamp); + if delete_range_start.is_none() { + delete_range_start = Some(timestamp); + } } else { // We could close the deletion range but it's not necessary because the new value will get reinserted anyway to_put.insert(timestamp, current);