snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-06-07 04:35:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Wait for the batched tasks bu their real uid.

Browse Source 
Some of them succeed, others fail.

Signed-off-by: Martin Tzvetanov Grigorov <mgrigorov@apache.org>
This commit is contained in:
Martin Tzvetanov Grigorov 2025-05-27 14:39:45 +03:00
parent f3d691667d
commit 3e0de6cb83
No known key found for this signature in database
GPG Key ID: 3194FD8C1AE300EF
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
crates/meilisearch/tests/documents/add_documents.rs
View File

@ -2924,8 +2924,10 @@ async fn batch_several_documents_addition() {
} }
// wait first batch of documents to finish // wait first batch of documents to finish
futures::future::join_all(waiter).await; let finished_tasks = futures::future::join_all(waiter).await;
index.wait_task(4).await.succeeded(); for (task, _code) in finished_tasks {
index.wait_task(task.uid()).await;
}
// run a second completely failing batch // run a second completely failing batch
documents[40] = json!({"title": "error", "desc": "error"}); documents[40] = json!({"title": "error", "desc": "error"});
@ -2936,8 +2938,10 @@ async fn batch_several_documents_addition() {
waiter.push(index.add_documents(json!(chunk), Some("id"))); waiter.push(index.add_documents(json!(chunk), Some("id")));
} }
// wait second batch of documents to finish // wait second batch of documents to finish
futures::future::join_all(waiter).await; let finished_tasks = futures::future::join_all(waiter).await;
index.wait_task(9).await.failed(); for (task, _code) in finished_tasks {
index.wait_task(task.uid()).await;
}
let (response, _code) = index.filtered_tasks(&[], &["failed"], &[]).await; let (response, _code) = index.filtered_tasks(&[], &["failed"], &[]).await;