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

Rename variable

Browse Source
This commit is contained in:
Mubelotix
2025-08-08 15:07:35 +02:00
parent ba0f0c3c30
commit cb36257537
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -571,9 +571,9 @@ impl IndexScheduler {
let processing_tasks = &self.processing_tasks.read().unwrap().processing.clone(); let processing_tasks = &self.processing_tasks.read().unwrap().processing.clone();
let all_task_ids = self.queue.tasks.all_task_ids(&rtxn)?; let all_task_ids = self.queue.tasks.all_task_ids(&rtxn)?;
let mut to_delete_tasks = all_task_ids & matched_tasks; let mut tasks_to_remove = all_task_ids & matched_tasks;
to_delete_tasks -= &**processing_tasks; tasks_to_remove -= &**processing_tasks;
to_delete_tasks -= &enqueued_tasks; tasks_to_remove -= &enqueued_tasks;
// 2. We now have a list of tasks to delete, delete them // 2. We now have a list of tasks to delete, delete them
let mut affected_indexes = HashSet::new(); let mut affected_indexes = HashSet::new();
@ -583,7 +583,7 @@ impl IndexScheduler {
// The tasks that have been removed *per batches*. // The tasks that have been removed *per batches*.
let mut affected_batches: HashMap<BatchId, RoaringBitmap> = HashMap::new(); let mut affected_batches: HashMap<BatchId, RoaringBitmap> = HashMap::new();
let (atomic_progress, task_progress) = AtomicTaskStep::new(to_delete_tasks.len() as u32); let (atomic_progress, task_progress) = AtomicTaskStep::new(tasks_to_remove.len() as u32);
progress.update_progress(task_progress); progress.update_progress(task_progress);
let mut min_enqueued = i128::MAX; let mut min_enqueued = i128::MAX;
let mut max_enqueued = i128::MIN; let mut max_enqueued = i128::MIN;
@ -594,7 +594,7 @@ impl IndexScheduler {
let mut enqueued_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new(); let mut enqueued_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new();
let mut started_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new(); let mut started_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new();
let mut finished_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new(); let mut finished_to_remove: HashMap<i128, RoaringBitmap> = HashMap::new();
for range in consecutive_ranges(to_delete_tasks.iter()) { for range in consecutive_ranges(tasks_to_remove.iter()) {
let iter = self let iter = self
.queue .queue
.tasks .tasks