We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8958935 commit 359405dCopy full SHA for 359405d
1 file changed
crates/integration-tests/src/test/tsa_campaign_suspension.rs
@@ -1,6 +1,6 @@
1
use crate::kumod::{DaemonWithTsa, MailGenParams};
2
use kumo_api_types::SuspendV1ListEntry;
3
-use kumo_log_types::RecordType::{Delivery, TransientFailure};
+use kumo_log_types::RecordType::{Delivery, Rejection, TransientFailure};
4
use std::time::Duration;
5
6
#[tokio::test]
@@ -30,6 +30,14 @@ async fn tsa_campaign_suspension() -> anyhow::Result<()> {
30
)
31
.await;
32
33
+ daemon
34
+ .with_maildir
35
+ .wait_for_sink_summary(
36
+ |summary| summary.get(&Rejection).copied().unwrap_or(0) > 1,
37
+ Duration::from_secs(50),
38
+ )
39
+ .await;
40
+
41
let delivery_summary = daemon.with_maildir.dump_logs().await?;
42
k9::snapshot!(
43
delivery_summary,
0 commit comments