searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-01-10 13:34:30 +01:00
Code Issues Releases Wiki Activity

fix the dumps missing the empty swap index tasks

Browse Source
This commit is contained in:
Tamo 2024-12-05 14:23:38 +01:00
parent 7a2af06b1e
commit 95975944d7
No known key found for this signature in database
GPG Key ID: 20CD8020AFA88D69
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
crates/index-scheduler/src/batch.rs
View File

@ -496,7 +496,7 @@ impl IndexScheduler {
// 5. We make a batch from the unprioritised tasks. Start by taking the next enqueued task. // 5. We make a batch from the unprioritised tasks. Start by taking the next enqueued task.
let task_id = if let Some(task_id) = enqueued.min() { task_id } else { return Ok(None) }; let task_id = if let Some(task_id) = enqueued.min() { task_id } else { return Ok(None) };
let task = self.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?; let mut task = self.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?;
// If the task is not associated with any index, verify that it is an index swap and // If the task is not associated with any index, verify that it is an index swap and
// create the batch directly. Otherwise, get the index name associated with the task // create the batch directly. Otherwise, get the index name associated with the task
@ -506,6 +506,7 @@ impl IndexScheduler {
index_name index_name
} else { } else {
assert!(matches!(&task.kind, KindWithContent::IndexSwap { swaps } if swaps.is_empty())); assert!(matches!(&task.kind, KindWithContent::IndexSwap { swaps } if swaps.is_empty()));
current_batch.processing(Some(&mut task));
return Ok(Some((Batch::IndexSwap { task }, current_batch))); return Ok(Some((Batch::IndexSwap { task }, current_batch)));
}; };

3
crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/third_empty_swap_processed.snap
View File

@ -89,7 +89,7 @@ succeeded [0,1,2,3,4,5,6,]
---------------------------------------------------------------------- ----------------------------------------------------------------------
### Batches Kind: ### Batches Kind:
"indexCreation" [0,1,2,3,] "indexCreation" [0,1,2,3,]
"indexSwap" [4,5,] "indexSwap" [4,5,6,]
---------------------------------------------------------------------- ----------------------------------------------------------------------
### Batches Index Tasks: ### Batches Index Tasks:
a [0,4,5,] a [0,4,5,]
@ -104,6 +104,7 @@ d [3,4,]
[timestamp] [3,] [timestamp] [3,]
[timestamp] [4,] [timestamp] [4,]
[timestamp] [5,] [timestamp] [5,]
[timestamp] [6,]
---------------------------------------------------------------------- ----------------------------------------------------------------------
### Batches Started At: ### Batches Started At:
[timestamp] [0,] [timestamp] [0,]