searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-07-04 12:27:13 +02:00
Code Issues Releases Wiki Activity

rename received_document_ids to matched_documents in the DocumentDeletion task type (reimplementation of #2826)

Browse source
This commit is contained in:
Irevoire 2022-10-25 11:02:26 +02:00
parent 37119d1295
commit d0c93e3573
No known key found for this signature in database
GPG key ID: 7A6A970C96104F1B
6 changed files with 22 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

2
index-scheduler/src/batch.rs
View file

@ -928,7 +928,7 @@ impl IndexScheduler {
for (task, documents) in tasks.iter_mut().zip(documents) {
task.status = Status::Succeeded;
task.details = Some(Details::DocumentDeletion {
received_document_ids: documents.len(),
matched_documents: documents.len(),
deleted_documents: Some(deleted_documents.min(documents.len() as u64)),
});
}

2
index-scheduler/src/snapshot.rs
View file

@ -164,7 +164,7 @@ fn snaphsot_details(d: &Details) -> String {
format!("{{ primary_key: {primary_key:?} }}")
}
Details::DocumentDeletion {
received_document_ids,
matched_documents: received_document_ids,
deleted_documents,
} => format!("{{ received_document_ids: {received_document_ids}, deleted_documents: {deleted_documents:?} }}"),
Details::ClearAll { deleted_documents } => {

5
index-scheduler/src/utils.rs
View file

@ -373,7 +373,10 @@ impl IndexScheduler {
}
_ => panic!(),
},
Details::DocumentDeletion { received_document_ids, deleted_documents } => {
Details::DocumentDeletion {
matched_documents: received_document_ids,
deleted_documents,
} => {
if let Some(deleted_documents) = deleted_documents {
assert_eq!(status, Status::Succeeded);
assert!(deleted_documents <= received_document_ids as u64);