mirror/kumomta
1
0
Fork 0
mirror of https://github.com/mailscope/kumomta.git synced 2026-09-21 01:05:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

ci: try to reduce flakiness for the lapin integration tests

Browse Source 
This seems to flake out reasonably regularly in CI on PRs.
Let's see if adjusting the ordering of things a little bit
encourages a less flakey result.
This commit is contained in:
Wez Furlong
2025-10-06 20:12:19 +01:00
parent 307d0b3093
commit 53a92c5cda
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/integration-tests/src/rabbit.rs
+8 -8
View File
@@ -61,9 +61,6 @@ async fn test_lapin_rabbit() -> anyhow::Result<()> {
.wait_for_maildir_count(1, Duration::from_secs(10))
.await;
daemon.stop_both().await.context("stop_both")?;
println!("Stopped!");
let mut consumer = channel
.basic_consume(
"woot",
@@ -76,21 +73,24 @@ async fn test_lapin_rabbit() -> anyhow::Result<()> {
let timeout = tokio::time::Duration::from_secs(20);
// Wait for Reception record
let delivery = tokio::time::timeout(timeout, consumer.next())
let reception = tokio::time::timeout(timeout, consumer.next())
.await?
.unwrap();
let delivery = delivery?;
println!("{}", String::from_utf8_lossy(&delivery.data));
delivery.ack(BasicAckOptions::default()).await?;
let reception = reception?;
println!("reception={}", String::from_utf8_lossy(&reception.data));
reception.ack(BasicAckOptions::default()).await?;
// Wait for Delivery record
let delivery = tokio::time::timeout(timeout, consumer.next())
.await?
.unwrap();
let delivery = delivery?;
println!("{}", String::from_utf8_lossy(&delivery.data));
println!("delivery={}", String::from_utf8_lossy(&delivery.data));
delivery.ack(BasicAckOptions::default()).await?;
daemon.stop_both().await.context("stop_both")?;
println!("Stopped!");
Ok(())
}