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 bug

Browse Source
This commit is contained in:
Mubelotix
2025-08-12 14:21:14 +02:00
parent e0f5e05b22
commit e9007effea
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -544,8 +544,8 @@ impl IndexScheduler {
return Ok(()); return Ok(());
} }
let min = to_remove.keys().min().cloned().unwrap_or(i128::MAX); let min = to_remove.keys().min().cloned().unwrap(); // to_remove isn't empty so this is ok
let max = to_remove.keys().max().cloned().unwrap_or(i128::MIN); let max = to_remove.keys().max().cloned().unwrap();
let range = min..=max; let range = min..=max;
// We iterate over the time database to see which ranges of timestamps need to be removed // We iterate over the time database to see which ranges of timestamps need to be removed
@ -573,7 +573,7 @@ impl IndexScheduler {
} }
} }
if let Some(delete_range_start) = delete_range_start.take() { if let Some(delete_range_start) = delete_range_start.take() {
delete_ranges.push(delete_range_start..i128::MAX); delete_ranges.push(delete_range_start..(max+1));
} }
for range in delete_ranges { for range in delete_ranges {
@ -779,18 +779,14 @@ impl IndexScheduler {
// 7. Remove task datetimes // 7. Remove task datetimes
progress.update_progress(TaskDeletionProgress::DeletingTasksDateTime); progress.update_progress(TaskDeletionProgress::DeletingTasksDateTime);
remove_task_datetimes(wtxn, tasks_enqueued_to_remove, self.queue.tasks.enqueued_at)?; remove_task_datetimes(wtxn, tasks_enqueued_to_remove, self.queue.tasks.enqueued_at)?;
remove_task_datetimes(wtxn, tasks_started_to_remove, self.queue.tasks.started_at)?; remove_task_datetimes(wtxn, tasks_started_to_remove, self.queue.tasks.started_at)?;
remove_task_datetimes(wtxn, tasks_finished_to_remove, self.queue.tasks.finished_at)?; remove_task_datetimes(wtxn, tasks_finished_to_remove, self.queue.tasks.finished_at)?;
// 8. Delete batches datetimes // 8. Delete batches datetimes
progress.update_progress(TaskDeletionProgress::DeletingBatchesDateTime); progress.update_progress(TaskDeletionProgress::DeletingBatchesDateTime);
remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.enqueued_at)?; remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.enqueued_at)?;
remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.started_at)?; remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.started_at)?;
remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.finished_at)?; remove_batch_datetimes(wtxn, &to_delete_batches, self.queue.batches.finished_at)?;
// 9. Remove batches metadata from indexes, statuses, and kinds // 9. Remove batches metadata from indexes, statuses, and kinds