fix(connector.py): do not connect multiple times when BlockingIOError encountered in Connector.connect()

2026-03-01 18:56:44 +01:00
parent b8fe5d66d4
commit 29ed2c8e5d
1 changed files with 2 additions and 2 deletions
--- a/src/judas_client/connector.py
+++ b/src/judas_client/connector.py
@@ -145,8 +145,8 @@ class Connector:
                self.socket.connect((self.host, self.port))
                connected = True
            except BlockingIOError:
-                # Connection in progress
-                time.sleep(0.1)
+                # connection in progress
+                connected = True
            except socket.error as e:
                self.logger.error(f"[!] Connection error: {e}")
                self.logger.debug(f"[.] Retrying in {delay} seconds...")