searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-11-29 16:24:26 +01:00
Code Issues Releases Wiki Activity

add one nanosecond to generated filter so as to generate a filter that would have matched the last task to delete

Browse Source
This commit is contained in:
Louis Dureuil 2023-05-04 09:56:48 +02:00
parent 52ab114f6c
commit b212aef5db
No known key found for this signature in database
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
index-scheduler/src/lib.rs
View File

@ -1137,13 +1137,17 @@ impl IndexScheduler {
// it's safe to unwrap here because we checked the len above // it's safe to unwrap here because we checked the len above
let newest_task_id = to_delete.iter().last().unwrap(); let newest_task_id = to_delete.iter().last().unwrap();
let task = self.get_task(&rtxn, newest_task_id)?.ok_or(Error::CorruptedTaskQueue)?; let last_task_to_delete =
self.get_task(&rtxn, newest_task_id)?.ok_or(Error::CorruptedTaskQueue)?;
drop(rtxn); drop(rtxn);
// increase time by one nanosecond so that the enqueuedAt of the last task to delete is also lower than that date.
let delete_before = last_task_to_delete.enqueued_at + Duration::from_nanos(1);
self.register(KindWithContent::TaskDeletion { self.register(KindWithContent::TaskDeletion {
query: format!( query: format!(
"?beforeEnqueuedAt={},status=succeeded,failed,canceled", "?beforeEnqueuedAt={},status=succeeded,failed,canceled",
task.enqueued_at.format(&Rfc3339).map_err(|_| Error::CorruptedTaskQueue)?, delete_before.format(&Rfc3339).map_err(|_| Error::CorruptedTaskQueue)?,
), ),
tasks: to_delete, tasks: to_delete,
})?; })?;