diff --git a/crates/meilisearch/tests/batches/mod.rs b/crates/meilisearch/tests/batches/mod.rs index dac1a2339..2f9fbbca7 100644 --- a/crates/meilisearch/tests/batches/mod.rs +++ b/crates/meilisearch/tests/batches/mod.rs @@ -283,7 +283,7 @@ async fn test_summarized_document_addition_or_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -301,13 +301,15 @@ async fn test_summarized_document_addition_or_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]", + "writeChannelCongestion": "[writeChannelCongestion]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); let (task, _status_code) = index.add_documents(json!({ "id": 42, "content": "doggos & fluff" }), Some("id")).await; @@ -322,7 +324,7 @@ async fn test_summarized_document_addition_or_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -340,13 +342,15 @@ async fn test_summarized_document_addition_or_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]", + "writeChannelCongestion": "[writeChannelCongestion]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -365,7 +369,7 @@ async fn test_summarized_delete_documents_by_batch() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -383,13 +387,14 @@ async fn test_summarized_delete_documents_by_batch() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); index.create(None).await; let (task, _status_code) = index.delete_batch(vec![42]).await; @@ -404,7 +409,7 @@ async fn test_summarized_delete_documents_by_batch() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 2, "progress": null, @@ -422,13 +427,14 @@ async fn test_summarized_delete_documents_by_batch() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -449,7 +455,7 @@ async fn test_summarized_delete_documents_by_filter() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -468,13 +474,14 @@ async fn test_summarized_delete_documents_by_filter() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); index.create(None).await; let (task, _status_code) = @@ -490,7 +497,7 @@ async fn test_summarized_delete_documents_by_filter() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 2, "progress": null, @@ -509,13 +516,14 @@ async fn test_summarized_delete_documents_by_filter() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); index.update_settings(json!({ "filterableAttributes": ["doggo"] })).await; let (task, _status_code) = @@ -550,7 +558,8 @@ async fn test_summarized_delete_documents_by_filter() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", @@ -566,7 +575,16 @@ async fn test_summarized_delete_document_by_id() { let (task, _status_code) = index.delete_document(1).await; index.wait_task(task.uid()).await.failed(); let (batch, _) = index.get_batch(0).await; - snapshot!(batch, + assert_json_snapshot!(batch, + { + ".uid" => "[uid]", + ".duration" => "[duration]", + ".enqueuedAt" => "[date]", + ".startedAt" => "[date]", + ".finishedAt" => "[date]", + ".stats.callTrace" => "[callTrace]", + ".stats.writeChannelCongestion" => "[writeChannelCongestion]" + }, @r#" { "uid": "[uid]", @@ -585,7 +603,8 @@ async fn test_summarized_delete_document_by_id() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", @@ -624,7 +643,8 @@ async fn test_summarized_delete_document_by_id() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", @@ -661,7 +681,7 @@ async fn test_summarized_settings_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -688,13 +708,14 @@ async fn test_summarized_settings_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -713,7 +734,7 @@ async fn test_summarized_index_creation() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -728,13 +749,14 @@ async fn test_summarized_index_creation() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); let (task, _status_code) = index.create(Some("doggos")).await; index.wait_task(task.uid()).await.failed(); @@ -748,7 +770,7 @@ async fn test_summarized_index_creation() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -765,13 +787,14 @@ async fn test_summarized_index_creation() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -900,7 +923,7 @@ async fn test_summarized_index_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -915,13 +938,14 @@ async fn test_summarized_index_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); let (task, _status_code) = index.update(Some("bones")).await; index.wait_task(task.uid()).await.failed(); @@ -935,7 +959,7 @@ async fn test_summarized_index_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -952,13 +976,14 @@ async fn test_summarized_index_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); // And run the same two tests once the index do exists. index.create(None).await; @@ -990,7 +1015,8 @@ async fn test_summarized_index_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", @@ -1010,7 +1036,7 @@ async fn test_summarized_index_update() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 4, "progress": null, @@ -1027,13 +1053,14 @@ async fn test_summarized_index_update() { }, "indexUids": { "test": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -1055,7 +1082,7 @@ async fn test_summarized_index_swap() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -1077,13 +1104,14 @@ async fn test_summarized_index_swap() { "types": { "indexSwap": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); server.index("doggos").create(None).await; let (task, _status_code) = server.index("cattos").create(None).await; @@ -1103,7 +1131,7 @@ async fn test_summarized_index_swap() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -1118,13 +1146,14 @@ async fn test_summarized_index_swap() { }, "indexUids": { "doggos": 1 - } + }, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -1146,7 +1175,7 @@ async fn test_summarized_batch_cancelation() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -1163,13 +1192,14 @@ async fn test_summarized_batch_cancelation() { "types": { "taskCancelation": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -1191,7 +1221,7 @@ async fn test_summarized_batch_deletion() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 1, "progress": null, @@ -1208,13 +1238,14 @@ async fn test_summarized_batch_deletion() { "types": { "taskDeletion": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } #[actix_web::test] @@ -1233,7 +1264,7 @@ async fn test_summarized_dump_creation() { ".stats.callTrace" => "[callTrace]", ".stats.writeChannelCongestion" => "[writeChannelCongestion]" }, - @r#" + @r###" { "uid": 0, "progress": null, @@ -1248,11 +1279,12 @@ async fn test_summarized_dump_creation() { "types": { "dumpCreation": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", "finishedAt": "[date]" } - "#); + "###); } diff --git a/crates/meilisearch/tests/dumps/snapshots/mod.rs/import_dump_v6_containing_batches_and_enqueued_tasks/batches.snap b/crates/meilisearch/tests/dumps/snapshots/mod.rs/import_dump_v6_containing_batches_and_enqueued_tasks/batches.snap index aeac6cf55..8d28aa706 100644 --- a/crates/meilisearch/tests/dumps/snapshots/mod.rs/import_dump_v6_containing_batches_and_enqueued_tasks/batches.snap +++ b/crates/meilisearch/tests/dumps/snapshots/mod.rs/import_dump_v6_containing_batches_and_enqueued_tasks/batches.snap @@ -1,6 +1,5 @@ --- source: crates/meilisearch/tests/dumps/mod.rs -snapshot_kind: text --- { "results": [ @@ -21,7 +20,9 @@ snapshot_kind: text }, "indexUids": { "kefir": 1 - } + }, + "callTrace": "[callTrace]", + "writeChannelCongestion": "[writeChannelCongestion]" }, "duration": "[date]", "startedAt": "[date]", diff --git a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41.snap b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41.snap index 6fe049b02..21fcdaffb 100644 --- a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41.snap +++ b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41.snap @@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs "types": { "upgradeDatabase": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", diff --git a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41.snap b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41.snap index 6fe049b02..21fcdaffb 100644 --- a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41.snap +++ b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41.snap @@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs "types": { "upgradeDatabase": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", diff --git a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterStartedAt_equal_2025-01-16T16_47_41.snap b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterStartedAt_equal_2025-01-16T16_47_41.snap index 6fe049b02..21fcdaffb 100644 --- a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterStartedAt_equal_2025-01-16T16_47_41.snap +++ b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/batches_filter_afterStartedAt_equal_2025-01-16T16_47_41.snap @@ -18,7 +18,8 @@ source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs "types": { "upgradeDatabase": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", diff --git a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/the_whole_batch_queue_once_everything_has_been_processed.snap b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/the_whole_batch_queue_once_everything_has_been_processed.snap index 63308dc64..4ed0abe17 100644 --- a/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/the_whole_batch_queue_once_everything_has_been_processed.snap +++ b/crates/meilisearch/tests/upgrade/v1_12/snapshots/v1_12_0.rs/check_the_index_scheduler/the_whole_batch_queue_once_everything_has_been_processed.snap @@ -1,6 +1,5 @@ --- source: crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs -snapshot_kind: text --- { "results": [ @@ -19,7 +18,8 @@ snapshot_kind: text "types": { "upgradeDatabase": 1 }, - "indexUids": {} + "indexUids": {}, + "callTrace": "[callTrace]" }, "duration": "[duration]", "startedAt": "[date]", diff --git a/crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs b/crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs index 2e71450d8..f3bff7467 100644 --- a/crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs +++ b/crates/meilisearch/tests/upgrade/v1_12/v1_12_0.rs @@ -159,7 +159,7 @@ async fn check_the_index_scheduler(server: &Server) { let (tasks, _) = server.tasks_filter("limit=1000").await; snapshot!(json_string!(tasks, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "the_whole_task_queue_once_everything_has_been_processed"); let (batches, _) = server.batches_filter("limit=1000").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "the_whole_batch_queue_once_everything_has_been_processed"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "the_whole_batch_queue_once_everything_has_been_processed"); // Tests all the tasks query parameters let (tasks, _) = server.tasks_filter("uids=10").await; @@ -186,32 +186,32 @@ async fn check_the_index_scheduler(server: &Server) { // Tests all the batches query parameters let (batches, _) = server.batches_filter("uids=10").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_uids_equal_10"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_uids_equal_10"); let (batches, _) = server.batches_filter("batchUids=10").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_batchUids_equal_10"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_batchUids_equal_10"); let (batches, _) = server.batches_filter("statuses=canceled").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_statuses_equal_canceled"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_statuses_equal_canceled"); // types has already been tested above to retrieve the upgrade database let (batches, _) = server.batches_filter("canceledBy=19").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_canceledBy_equal_19"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_canceledBy_equal_19"); let (batches, _) = server.batches_filter("beforeEnqueuedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeEnqueuedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeEnqueuedAt_equal_2025-01-16T16_47_41"); let (batches, _) = server.batches_filter("afterEnqueuedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterEnqueuedAt_equal_2025-01-16T16_47_41"); let (batches, _) = server.batches_filter("beforeStartedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeStartedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeStartedAt_equal_2025-01-16T16_47_41"); let (batches, _) = server.batches_filter("afterStartedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterStartedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterStartedAt_equal_2025-01-16T16_47_41"); let (batches, _) = server.batches_filter("beforeFinishedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_beforeFinishedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_beforeFinishedAt_equal_2025-01-16T16_47_41"); let (batches, _) = server.batches_filter("afterFinishedAt=2025-01-16T16:47:41Z").await; - snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]" }), name: "batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41"); + snapshot!(json_string!(batches, { ".results[0].duration" => "[duration]", ".results[0].enqueuedAt" => "[date]", ".results[0].startedAt" => "[date]", ".results[0].finishedAt" => "[date]", ".results[0].stats.callTrace" => "[callTrace]", ".results[0].stats.writeChannelCongestion" => "[writeChannelCongestion]" }), name: "batches_filter_afterFinishedAt_equal_2025-01-16T16_47_41"); let (stats, _) = server.stats().await; snapshot!(stats, @r###" { "databaseSize": 438272, - "usedDatabaseSize": 196608, + "usedDatabaseSize": 200704, "lastUpdate": "2025-01-23T11:36:22.634859166Z", "indexes": { "kefir": {