diff --git a/tap-agent/src/agent/sender_account.rs b/tap-agent/src/agent/sender_account.rs index 0366a634..ec86ba5e 100644 --- a/tap-agent/src/agent/sender_account.rs +++ b/tap-agent/src/agent/sender_account.rs @@ -1079,7 +1079,7 @@ pub mod tests { )) .unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(20)).await; assert_eq!( triggered_rav_request.load(std::sync::atomic::Ordering::SeqCst), @@ -1189,7 +1189,7 @@ pub mod tests { }, )) .unwrap(); - tokio::time::sleep(Duration::from_millis(30)).await; + tokio::time::sleep(Duration::from_millis(100)).await; let retry_value = triggered_rav_request.load(std::sync::atomic::Ordering::SeqCst); assert!(retry_value > 1, "It didn't retry more than once"); @@ -1236,7 +1236,7 @@ pub mod tests { )) .unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(20)).await; }; } @@ -1252,7 +1252,7 @@ pub mod tests { )) .unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(20)).await; }; } @@ -1519,7 +1519,7 @@ pub mod tests { HashMap::from([(SENDER.1, vec![SIGNER.1])]), )); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(20)).await; let deny = call!(sender_account, SenderAccountMessage::GetDeny).unwrap(); assert!(deny, "should block the sender"); diff --git a/tap-agent/src/agent/sender_accounts_manager.rs b/tap-agent/src/agent/sender_accounts_manager.rs index cc88a09f..eb4582de 100644 --- a/tap-agent/src/agent/sender_accounts_manager.rs +++ b/tap-agent/src/agent/sender_accounts_manager.rs @@ -734,7 +734,7 @@ mod tests { )) .unwrap(); - tokio::time::sleep(std::time::Duration::from_millis(10)).await; + tokio::time::sleep(std::time::Duration::from_millis(20)).await; // verify if it gets removed let actor_ref = ActorRef::::where_is(format!("{}:{}", prefix, SENDER.1)); diff --git a/tap-agent/src/agent/sender_allocation.rs b/tap-agent/src/agent/sender_allocation.rs index db5f4a37..bcc30f38 100644 --- a/tap-agent/src/agent/sender_allocation.rs +++ b/tap-agent/src/agent/sender_allocation.rs @@ -1126,7 +1126,7 @@ pub mod tests { .await; sender_allocation.stop_and_wait(None, None).await.unwrap(); - tokio::time::sleep(std::time::Duration::from_millis(10)).await; + tokio::time::sleep(std::time::Duration::from_millis(20)).await; // check if the actor is actually stopped assert_eq!(sender_allocation.get_status(), ActorStatus::Stopped);