diff --git a/src/judas_client/connector.py b/src/judas_client/connector.py index 7f7ec53..d30f7bf 100644 --- a/src/judas_client/connector.py +++ b/src/judas_client/connector.py @@ -118,6 +118,7 @@ class Connector: self.logger.warning( "[!] Data not acknowledged, retrying..." ) + except BrokenPipeError as e: self.logger.error(f"[!] Broken pipe: {e}") self.logger.info("[.] Reconnecting...")