diff --git a/crates/index-scheduler/src/scheduler/process_batch.rs b/crates/index-scheduler/src/scheduler/process_batch.rs index 7132fcee0..43a28fe13 100644 --- a/crates/index-scheduler/src/scheduler/process_batch.rs +++ b/crates/index-scheduler/src/scheduler/process_batch.rs @@ -127,6 +127,12 @@ impl IndexScheduler { _ => unreachable!(), } } + + debug_assert!( + deleted_tasks.is_empty(), + "There should be no tasks left to delete after processing the batch" + ); + Ok((tasks, ProcessBatchInfo::default())) } Batch::SnapshotCreation(tasks) => self