snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-31 07:56:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Do not explode on missing content file if the task has no docs

Browse Source
This commit is contained in:
Louis Dureuil
2025-01-16 16:54:44 +01:00
parent a6470a0c37
commit 805531c90d
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -39,6 +39,8 @@ impl<'a> Dump<'a> {
task: TaskDump, task: TaskDump,
content_file: Option<Box<UpdateFile>>, content_file: Option<Box<UpdateFile>>,
) -> Result<Task> { ) -> Result<Task> {
let task_has_no_docs = matches!(task.kind, KindDump::DocumentImport { documents_count, .. } if documents_count == 0);
let content_uuid = match content_file { let content_uuid = match content_file {
Some(content_file) if task.status == Status::Enqueued => { Some(content_file) if task.status == Status::Enqueued => {
let (uuid, mut file) = self.index_scheduler.queue.create_update_file(false)?; let (uuid, mut file) = self.index_scheduler.queue.create_update_file(false)?;
@@ -54,6 +56,14 @@ impl<'a> Dump<'a> {
// If the task isn't `Enqueued` then just generate a recognisable `Uuid` // If the task isn't `Enqueued` then just generate a recognisable `Uuid`
// in case we try to open it later. // in case we try to open it later.
_ if task.status != Status::Enqueued => Some(Uuid::nil()), _ if task.status != Status::Enqueued => Some(Uuid::nil()),
None if task.status == Status::Enqueued && task_has_no_docs => {
let (uuid, mut file) = self.index_scheduler.queue.create_update_file(false)?;
let builder = DocumentsBatchBuilder::new(&mut file);
builder.into_inner()?;
file.persist()?;
Some(uuid)
}
_ => None, _ => None,
}; };