From 9e687ccae844cb2fe172b0680cb3edf5e8925541 Mon Sep 17 00:00:00 2001
From: mivik <mivikq@gmail.com>
Date: Wed, 16 Apr 2025 15:53:53 +0800
Subject: [PATCH] feat(node): add warning for discarding events

---
 apis/rust/node/src/event_stream/scheduler.rs | 1 +
 1 file changed, 1 insertion(+)

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);