We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 48d6360 commit 5635814Copy full SHA for 5635814
1 file changed
data-pipeline/src/stats_exporter.rs
@@ -342,15 +342,12 @@ mod tests {
342
cancellation_token.clone(),
343
);
344
345
- tokio::time::pause();
346
tokio::spawn(async move {
347
stats_exporter.run().await;
348
});
349
// Cancel token to trigger force flush
350
cancellation_token.cancel();
351
- // Resume time to sleep while the stats are being sent
352
- tokio::time::resume();
353
- tokio::time::sleep(Duration::from_millis(10)).await;
+ tokio::time::sleep(Duration::from_millis(500)).await;
354
355
mock.assert_async().await;
356
}
0 commit comments