From 7a93a2582b5c099e36dc68a8fcc7e74b15af38cf Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Fri, 10 Apr 2026 14:28:50 -0400 Subject: [PATCH] better warning in bounded_queue_sync --- src/client/sync/bounded_queue_sync.ml | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/client/sync/bounded_queue_sync.ml b/src/client/sync/bounded_queue_sync.ml index dfad51e9..99025aa4 100644 --- a/src/client/sync/bounded_queue_sync.ml +++ b/src/client/sync/bounded_queue_sync.ml @@ -101,8 +101,9 @@ let push (self : _ state) x = if num_discarded > 0 then ( ignore (Atomic.fetch_and_add self.n_discarded num_discarded : int); Opentelemetry.Self_debug.log Warning (fun () -> - Printf.sprintf "otel: dropped %d signals (exporter queue full)" - num_discarded) + Printf.sprintf + "otel: dropped %d signals (exporter queue full at %d)" + num_discarded self.high_watermark) ); (* wake up potentially asleep consumers *) Cb_set.trigger self.on_non_empty