From 8e390278f53dd7a8b1cbd5f1cd68abcdc4f232df Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Sun, 23 Jan 2022 19:40:00 -0500
Subject: [PATCH] Handle logging against IPC stream vs. throttled channel on
 overruns

---
 piker/data/_sampling.py | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index db3f53b2..5e702e08 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -253,11 +253,17 @@ async def sample_and_broadcast(
                             try:
                                 stream.send_nowait((sym, quote))
                             except trio.WouldBlock:
-                                log.warning(
-                                    f'Feed overrun {bus.brokername} ->'
-                                    f'{stream._ctx.channel.uid} !!!'
-                                )
-
+                                ctx = getattr(sream, '_ctx', None)
+                                if ctx:
+                                    log.warning(
+                                        f'Feed overrun {bus.brokername} ->'
+                                        f'{ctx.channel.uid} !!!'
+                                    )
+                                else:
+                                    log.warning(
+                                        f'Feed overrun {bus.brokername} -> '
+                                        f'feed @ {tick_throttle} Hz'
+                                    )
                         else:
                             await stream.send({sym: quote})