2025-09-19 13:34:37 +00:00
1 changed files with 27 additions and 12 deletions
--- 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...")