Skip to content

Commit fd57818

Browse files
committed
When sending the Connect message, use the connection timeout
1 parent 863edb5 commit fd57818

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

kazoo/protocol/connection.py

+1-3
Original file line numberDiff line numberDiff line change
@@ -727,9 +727,7 @@ def _connect(self, host, hostip, port, timeout):
727727
client.read_only,
728728
)
729729

730-
connect_result, zxid = self._invoke(
731-
client._session_timeout / 1000.0 / len(client.hosts), connect
732-
)
730+
connect_result, zxid = self._invoke(timeout, connect)
733731

734732
if connect_result.time_out <= 0:
735733
raise SessionExpiredError("Session has expired")

0 commit comments

Comments
 (0)