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

Fix batch id detection

Browse Source 
Signed-off-by: Martin Tzvetanov Grigorov <mgrigorov@apache.org>
This commit is contained in:
Martin Tzvetanov Grigorov
2025-07-11 10:24:25 +03:00
parent 3bef4f4413
commit eb6ad3ef9c
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/meilisearch/tests/batches/mod.rs
View File

@ -346,6 +346,7 @@ async fn test_summarized_document_addition_or_update() {
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.internalDatabaseSizes" => "[internalDatabaseSizes]", ".stats.internalDatabaseSizes" => "[internalDatabaseSizes]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -438,6 +439,7 @@ async fn test_summarized_delete_documents_by_batch() {
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.internalDatabaseSizes" => "[internalDatabaseSizes]", ".stats.internalDatabaseSizes" => "[internalDatabaseSizes]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -1127,8 +1129,8 @@ async fn test_summarized_index_swap() {
{ "indexes": ["doggos", "cattos"] } { "indexes": ["doggos", "cattos"] }
])) ]))
.await; .await;
server.wait_task(task.uid()).await.failed(); let task = server.wait_task(task.uid()).await.failed();
let (batch, _) = server.get_batch(task.uid() as u32).await; let (batch, _) = server.get_batch(task.batch_uid()).await;
assert_json_snapshot!(batch, assert_json_snapshot!(batch,
{ {
".uid" => "[uid]", ".uid" => "[uid]",
@ -1181,8 +1183,8 @@ async fn test_summarized_index_swap() {
{ "indexes": [doggos_index.uid, cattos_index.uid] } { "indexes": [doggos_index.uid, cattos_index.uid] }
])) ]))
.await; .await;
server.wait_task(task.uid()).await.succeeded(); let task = server.wait_task(task.uid()).await.succeeded();
let (batch, _) = server.get_batch(task.uid() as u32).await; let (batch, _) = server.get_batch(task.batch_uid()).await;
assert_json_snapshot!(batch, assert_json_snapshot!(batch,
{ {
".uid" => "[uid]", ".uid" => "[uid]",