diff --git a/artiq/protocols/sync_struct.py b/artiq/protocols/sync_struct.py index e2c1021ad..e7100701d 100644 --- a/artiq/protocols/sync_struct.py +++ b/artiq/protocols/sync_struct.py @@ -236,7 +236,7 @@ class Publisher(AsyncioServer): await writer.drain() finally: self._recipients[notifier_name].remove(queue) - except ConnectionResetError: + except (ConnectionResetError, BrokenPipeError): # subscribers disconnecting are a normal occurence pass finally: