From 2bec97dbe1b67bcf57c19d9111bcf17f0e242f8a Mon Sep 17 00:00:00 2001 From: Wez Furlong Date: Thu, 18 Dec 2025 14:12:05 +0000 Subject: [PATCH] ci: fixup some flakeyness in maildir_batch_452_b --- crates/integration-tests/src/test/maildir_batch_452.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/crates/integration-tests/src/test/maildir_batch_452.rs b/crates/integration-tests/src/test/maildir_batch_452.rs index f4661cb7..a134ebce 100644 --- a/crates/integration-tests/src/test/maildir_batch_452.rs +++ b/crates/integration-tests/src/test/maildir_batch_452.rs @@ -1,7 +1,7 @@ use crate::kumod::{DaemonWithMaildirOptions, MailGenParams}; use anyhow::Context; use k9::assert_equal; -use kumo_log_types::RecordType::TransientFailure; +use kumo_log_types::RecordType::{Delivery, TransientFailure}; use std::time::Duration; #[tokio::test] @@ -190,7 +190,13 @@ async fn maildir_batch_452_b() -> anyhow::Result<()> { anyhow::ensure!(status.response.code == 250); daemon - .wait_for_maildir_count(1, Duration::from_secs(10)) + .wait_for_source_summary( + |summary| { + summary.get(&Delivery).copied().unwrap_or(0) == 1 + && summary.get(&TransientFailure).copied().unwrap_or(0) > 0 + }, + Duration::from_secs(10), + ) .await; daemon.stop_both().await.context("stop_both")?;