From 94caa248e789c2b29469afd1bdc5ddd164657575 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Mon, 9 Jun 2025 10:27:01 -0400 Subject: [PATCH] TO-CHERRY: another sampler EoC suppression case? Not sure whether this should get cherried onto `stop_is_eoc` or `brokers_refinery` (need to a diff between the two first) but seems like this might be the final resiliency update? :pray: --- piker/data/_sampling.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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' )