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 kinds not being deleted

Browse Source
This commit is contained in:
Mubelotix
2025-08-12 14:06:48 +02:00
parent 72ea3efdd5
commit fee2fed044
1 changed files with 21 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -821,21 +821,33 @@ impl IndexScheduler {
); );
progress.update_progress(task_progress); progress.update_progress(task_progress);
for (index, mut previous_tasks) in affected_indexes_tasks.into_iter() { for (index, mut tasks) in affected_indexes_tasks.into_iter() {
previous_tasks -= &to_delete_tasks; tasks -= &to_delete_tasks;
self.queue.tasks.index_tasks.put(wtxn, index, &previous_tasks)?; if tasks.is_empty() {
self.queue.tasks.index_tasks.delete(wtxn, index)?;
} else {
self.queue.tasks.index_tasks.put(wtxn, index, &tasks)?;
}
atomic_progress.fetch_add(1, Ordering::Relaxed); atomic_progress.fetch_add(1, Ordering::Relaxed);
} }
for (status, mut previous_tasks) in affected_statuses_tasks.into_iter() { for (status, mut tasks) in affected_statuses_tasks.into_iter() {
previous_tasks -= &to_delete_tasks; tasks -= &to_delete_tasks;
self.queue.tasks.status.put(wtxn, &status, &previous_tasks)?; if tasks.is_empty() {
self.queue.tasks.status.delete(wtxn, &status)?;
} else {
self.queue.tasks.status.put(wtxn, &status, &tasks)?;
}
atomic_progress.fetch_add(1, Ordering::Relaxed); atomic_progress.fetch_add(1, Ordering::Relaxed);
} }
for (kind, mut previous_tasks) in affected_kinds_tasks.into_iter() { for (kind, mut tasks) in affected_kinds_tasks.into_iter() {
previous_tasks -= &to_delete_tasks; tasks -= &to_delete_tasks;
self.queue.tasks.kind.put(wtxn, &kind, &previous_tasks)?; if tasks.is_empty() {
self.queue.tasks.kind.delete(wtxn, &kind)?;
} else {
self.queue.tasks.kind.put(wtxn, &kind, &tasks)?;
}
atomic_progress.fetch_add(1, Ordering::Relaxed); atomic_progress.fetch_add(1, Ordering::Relaxed);
} }