snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-09-06 04:36:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix mistake

Browse Source
This commit is contained in:
Mubelotix
2025-08-08 16:04:10 +02:00
parent 1cb9816f44
commit 05c0b6ee6e
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/index-scheduler/src/scheduler/process_batch.rs
View File

@ -892,20 +892,20 @@ impl IndexScheduler {
progress.update_progress(TaskDeletionProgress::DeletingBatchesMetadata); progress.update_progress(TaskDeletionProgress::DeletingBatchesMetadata);
for (index, batches) in to_remove_from_indexes { for (index, batches) in to_remove_from_indexes {
self.queue.tasks.update_index(wtxn, index, |index_tasks| { self.queue.batches.update_index(wtxn, index, |b| {
*index_tasks -= &batches; *b -= &batches;
})?; })?;
} }
for (status, batches) in to_remove_from_statuses { for (status, batches) in to_remove_from_statuses {
self.queue.tasks.update_status(wtxn, status, |status_tasks| { self.queue.batches.update_status(wtxn, status, |b| {
*status_tasks -= &batches; *b -= &batches;
})?; })?;
} }
for (kind, batches) in to_remove_from_kinds { for (kind, batches) in to_remove_from_kinds {
self.queue.tasks.update_kind(wtxn, kind, |kind_tasks| { self.queue.batches.update_kind(wtxn, kind, |b| {
*kind_tasks -= &batches; *b -= &batches;
})?; })?;
} }