diff --git a/apis/rust/node/src/event_stream/scheduler.rs b/apis/rust/node/src/event_stream/scheduler.rs index 89165678..f8783732 100644 --- a/apis/rust/node/src/event_stream/scheduler.rs +++ b/apis/rust/node/src/event_stream/scheduler.rs @@ -54,6 +54,7 @@ impl Scheduler { if let Some((size, queue)) = self.event_queues.get_mut(event_id) { // Remove the oldest event if at limit if &queue.len() >= size { + tracing::warn!("Discarding event for input `{event_id}` due to queue size limit"); queue.pop_front(); } queue.push_back(event);