From 05c0b6ee6efb3615476ccd6ae7316d2462a62431 Mon Sep 17 00:00:00 2001 From: Mubelotix Date: Fri, 8 Aug 2025 16:04:10 +0200 Subject: [PATCH] Fix mistake --- .../index-scheduler/src/scheduler/process_batch.rs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/crates/index-scheduler/src/scheduler/process_batch.rs b/crates/index-scheduler/src/scheduler/process_batch.rs index 8f784053f..5211b8eb7 100644 --- a/crates/index-scheduler/src/scheduler/process_batch.rs +++ b/crates/index-scheduler/src/scheduler/process_batch.rs @@ -892,20 +892,20 @@ impl IndexScheduler { progress.update_progress(TaskDeletionProgress::DeletingBatchesMetadata); for (index, batches) in to_remove_from_indexes { - self.queue.tasks.update_index(wtxn, index, |index_tasks| { - *index_tasks -= &batches; + self.queue.batches.update_index(wtxn, index, |b| { + *b -= &batches; })?; } for (status, batches) in to_remove_from_statuses { - self.queue.tasks.update_status(wtxn, status, |status_tasks| { - *status_tasks -= &batches; + self.queue.batches.update_status(wtxn, status, |b| { + *b -= &batches; })?; } for (kind, batches) in to_remove_from_kinds { - self.queue.tasks.update_kind(wtxn, kind, |kind_tasks| { - *kind_tasks -= &batches; + self.queue.batches.update_kind(wtxn, kind, |b| { + *b -= &batches; })?; }