More tests fixes

Signed-off-by: Martin Tzvetanov Grigorov <mgrigorov@apache.org>
This commit is contained in:
Martin Tzvetanov Grigorov
2025-07-11 11:11:46 +03:00
parent 1eb6cd38ce
commit a39223822a

View File

@ -396,7 +396,7 @@ async fn test_summarized_delete_documents_by_batch() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => "batched all enqueued tasks", ".batchStrategy" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -439,7 +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", ".batchStrategy" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -532,7 +532,7 @@ async fn test_summarized_delete_documents_by_filter() {
".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", ".batchStrategy" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -667,7 +667,7 @@ async fn test_summarized_delete_document_by_id() {
".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", ".batchStrategy" => "batched all enqueued tasks",
}, },
@r###" @r###"
{ {
@ -781,7 +781,7 @@ async fn test_summarized_index_creation() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -802,7 +802,7 @@ async fn test_summarized_index_creation() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexCreation` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexCreation` that cannot be batched with any other task."
} }
"###); "###);
@ -819,7 +819,7 @@ async fn test_summarized_index_creation() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -842,7 +842,7 @@ async fn test_summarized_index_creation() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexCreation` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexCreation` that cannot be batched with any other task."
} }
"###); "###);
} }
@ -974,7 +974,7 @@ async fn test_summarized_index_update() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -995,7 +995,7 @@ async fn test_summarized_index_update() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexUpdate` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexUpdate` that cannot be batched with any other task."
} }
"###); "###);
@ -1012,7 +1012,7 @@ async fn test_summarized_index_update() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1035,7 +1035,7 @@ async fn test_summarized_index_update() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexUpdate` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexUpdate` that cannot be batched with any other task."
} }
"###); "###);
@ -1055,7 +1055,7 @@ async fn test_summarized_index_update() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1076,7 +1076,7 @@ async fn test_summarized_index_update() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexUpdate` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexUpdate` that cannot be batched with any other task."
} }
"###); "###);
@ -1093,7 +1093,7 @@ async fn test_summarized_index_update() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1116,7 +1116,7 @@ async fn test_summarized_index_update() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexUpdate` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexUpdate` that cannot be batched with any other task."
} }
"###); "###);
} }
@ -1140,7 +1140,7 @@ async fn test_summarized_index_swap() {
".finishedAt" => "[date]", ".finishedAt" => "[date]",
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1170,7 +1170,7 @@ async fn test_summarized_index_swap() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexSwap` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexSwap` that cannot be batched with any other task."
} }
"###); "###);
@ -1195,7 +1195,7 @@ async fn test_summarized_index_swap() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".stats.indexUids" => r#"{"[uuid]": 1}"#, ".stats.indexUids" => r#"{"[uuid]": 1}"#,
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1216,7 +1216,7 @@ async fn test_summarized_index_swap() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `indexCreation` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `indexCreation` that cannot be batched with any other task."
} }
"###); "###);
} }
@ -1241,7 +1241,7 @@ async fn test_summarized_batch_cancelation() {
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".details.originalFilter" => "?uids=X", ".details.originalFilter" => "?uids=X",
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1266,7 +1266,7 @@ async fn test_summarized_batch_cancelation() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `taskCancelation` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `taskCancelation` that cannot be batched with any other task."
} }
"###); "###);
} }
@ -1336,7 +1336,7 @@ async fn test_summarized_dump_creation() {
".finishedAt" => "[date]", ".finishedAt" => "[date]",
".stats.progressTrace" => "[progressTrace]", ".stats.progressTrace" => "[progressTrace]",
".stats.writeChannelCongestion" => "[writeChannelCongestion]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]",
".batchCreationComplete" => insta::dynamic_redaction(task_with_id_redaction), ".batchStrategy" => insta::dynamic_redaction(task_with_id_redaction),
}, },
@r###" @r###"
{ {
@ -1359,7 +1359,7 @@ async fn test_summarized_dump_creation() {
"duration": "[duration]", "duration": "[duration]",
"startedAt": "[date]", "startedAt": "[date]",
"finishedAt": "[date]", "finishedAt": "[date]",
"batchCreationComplete": "task with id X of type `dumpCreation` cannot be batched" "batchStrategy": "created batch containing only task with id X of type `dumpCreation` that cannot be batched with any other task."
} }
"###); "###);
} }