snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-26 12:05:05 +08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

use TaskEvent method instead of variants in BatchHandler impl

Browse Source
This commit is contained in:
ad hoc 2022-05-26 11:50:04 +02:00
parent 1647ca3c1f
commit 5a2972fc19
No known key found for this signature in database
GPG Key ID: 4F00A782990CC643
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
meilisearch-lib/src/tasks/handlers/index_resolver_handler.rs
View File

@ -1,5 +1,3 @@
use time::OffsetDateTime;
use crate::index_resolver::IndexResolver; use crate::index_resolver::IndexResolver;
use crate::index_resolver::{index_store::IndexStore, meta_store::IndexMetaStore}; use crate::index_resolver::{index_store::IndexStore, meta_store::IndexMetaStore};
use crate::tasks::batch::{Batch, BatchContent}; use crate::tasks::batch::{Batch, BatchContent};
@ -27,16 +25,8 @@ where
.await; .await;
} }
BatchContent::IndexUpdate(ref mut task) => match self.process_task(task).await { BatchContent::IndexUpdate(ref mut task) => match self.process_task(task).await {
Ok(success) => { Ok(success) => task.events.push(TaskEvent::succeeded(success)),
task.events.push(TaskEvent::Succeded { Err(err) => task.events.push(TaskEvent::failed(err.into())),
result: success,
timestamp: OffsetDateTime::now_utc(),
});
}
Err(err) => task.events.push(TaskEvent::Failed {
error: err.into(),
timestamp: OffsetDateTime::now_utc(),
}),
}, },
_ => unreachable!(), _ => unreachable!(),
} }