When sending the Connect message, use the connection timeout

python-zk · Nov 26, 2022 · fd57818 · fd57818
1 parent 863edb5
commit fd57818
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/kazoo/protocol/connection.py b/kazoo/protocol/connection.py
@@ -727,9 +727,7 @@ def _connect(self, host, hostip, port, timeout):
             client.read_only,
         )
 
-        connect_result, zxid = self._invoke(
-            client._session_timeout / 1000.0 / len(client.hosts), connect
-        )
+        connect_result, zxid = self._invoke(timeout, connect)
 
         if connect_result.time_out <= 0:
             raise SessionExpiredError("Session has expired")