handle closed/full queues in eventlog

merlinz01 · Jun 15, 2024 · c625eb7 · c625eb7
1 parent 11c9c09
commit c625eb7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/redpepper/manager/eventlog.py b/redpepper/manager/eventlog.py
@@ -20,7 +20,10 @@ def add_consumer(self):
         send, recv = trio.open_memory_channel(10)
         self.consumers[id(recv)] = send
         for event in self.most_recent:
-            send.send_nowait(event)
+            try:
+                send.send_nowait(event)
+            except (trio.WouldBlock, trio.ClosedResourceError) as e:
+                logger.warn("Event bus consumer queue full or closed: %s", e)
         return recv
 
     def remove_consumer(self, consumer):