diff --git a/interceptor/src/report/receiver/mod.rs b/interceptor/src/report/receiver/mod.rs index 5a5e21579..19fc8e558 100644 --- a/interceptor/src/report/receiver/mod.rs +++ b/interceptor/src/report/receiver/mod.rs @@ -86,6 +86,8 @@ impl ReceiverReport { internal: Arc, ) -> Result<()> { let mut ticker = tokio::time::interval(internal.interval); + ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip); + let mut close_rx = { let mut close_rx = internal.close_rx.lock().await; if let Some(close) = close_rx.take() { diff --git a/interceptor/src/report/sender/mod.rs b/interceptor/src/report/sender/mod.rs index f46c54933..81a832132 100644 --- a/interceptor/src/report/sender/mod.rs +++ b/interceptor/src/report/sender/mod.rs @@ -47,6 +47,8 @@ impl SenderReport { internal: Arc, ) -> Result<()> { let mut ticker = tokio::time::interval(internal.interval); + ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip); + let mut close_rx = { let mut close_rx = internal.close_rx.lock().await; if let Some(close) = close_rx.take() {