Extend test sleep
@@ -358,7 +358,7 @@ impl TestPipeline {
/// wait for up to 2 seconds for an event to arrive
pub(crate) async fn get_event(&self) -> Result<Event> {
let start = Instant::now();
- const TIMEOUT: Duration = Duration::from_secs(20);
+ const TIMEOUT: Duration = Duration::from_secs(120);
loop {
match self.rx.recv().timeout(TIMEOUT).await {
Ok(Ok(msg)) => {
