diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index 37d7623f..ffb66ac7 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -284,7 +284,8 @@ class Sampler:
 
                     except (
                         trio.BrokenResourceError,
-                        trio.ClosedResourceError
+                        trio.ClosedResourceError,
+                        trio.EndOfChannel,
                     ):
                         log.error(
                             f'{stream._ctx.chan.uid} dropped connection'
@@ -697,7 +698,7 @@ async def sample_and_broadcast(
 
                                 log.warning(
                                     f'Feed OVERRUN {sub_key}'
-                                    '@{bus.brokername} -> \n'
+                                    f'@{bus.brokername} -> \n'
                                     f'feed @ {chan.uid}\n'
                                     f'throttle = {throttle} Hz'
                                 )