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? 🙏
decimal_prices_thru_ems
Tyler Goodlet 2025-06-09 10:27:01 -04:00
parent da953b6b0c
commit 94caa248e7
1 changed files with 3 additions and 2 deletions

View File

@ -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'
)