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 a6579dfb..bcc30f38 100644 --- a/tap-agent/src/agent/sender_allocation.rs +++ b/tap-agent/src/agent/sender_allocation.rs @@ -272,7 +272,9 @@ impl Actor for SenderAllocation { SenderAllocationMessage::TriggerRAVRequest(reply) => { if state.unaggregated_fees.value > 0 { // auto backoff retry, on error ignore - let _ = state.request_rav().await; + if let Err(err) = state.request_rav().await { + error!(error = %err, "Error while requesting rav."); + } } if !reply.is_closed() { let _ = reply.send((state.unaggregated_fees.clone(), state.latest_rav.clone())); @@ -1124,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);