diff --git a/piker/clearing/_ems.py b/piker/clearing/_ems.py index 96c01df8..a5939eb7 100644 --- a/piker/clearing/_ems.py +++ b/piker/clearing/_ems.py @@ -729,6 +729,7 @@ class Router(Struct): except ( trio.ClosedResourceError, trio.BrokenResourceError, + tractor.TransportClosed, ): to_remove.add(client_stream) log.warning( @@ -1699,5 +1700,5 @@ async def _emsd_main( if not client_streams: log.warning( f'Order dialog is not being monitored:\n' - f'{oid} ->\n{client_stream._ctx.chan.uid}' + f'{oid!r} <-> {client_stream.chan.aid.reprol()}\n' ) diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py index 609218ad..c81f79eb 100644 --- a/piker/data/_sampling.py +++ b/piker/data/_sampling.py @@ -99,6 +99,7 @@ class Sampler: trio.BrokenResourceError, trio.ClosedResourceError, trio.EndOfChannel, + tractor.TransportClosed, ) # holds all the ``tractor.Context`` remote subscriptions for @@ -753,7 +754,7 @@ async def sample_and_broadcast( log.warning( f'Feed OVERRUN {sub_key}' f'@{bus.brokername} -> \n' - f'feed @ {chan.uid}\n' + f'feed @ {chan.aid.reprol()}\n' f'throttle = {throttle} Hz' )