Skip to content

Commit 4b7132b

Browse files
authored
Merge pull request apache#639 from datastax/617
PYTHON-617 - Wait for first *successful* connect on initial
2 parents d244ece + c6b1b8d commit 4b7132b

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

cassandra/cluster.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1927,8 +1927,10 @@ def __init__(self, cluster, hosts, keyspace=None):
19271927
future = self.add_or_renew_pool(host, is_host_addition=False)
19281928
if future:
19291929
self._initial_connect_futures.add(future)
1930-
wait_futures(self._initial_connect_futures, return_when=FIRST_COMPLETED)
19311930

1931+
futures = wait_futures(self._initial_connect_futures, return_when=FIRST_COMPLETED)
1932+
while futures.not_done and not any(f.result() for f in futures.done):
1933+
futures = wait_futures(futures.not_done, return_when=FIRST_COMPLETED)
19321934

19331935
def execute(self, query, parameters=None, timeout=_NOT_SET, trace=False, custom_payload=None, execution_profile=EXEC_PROFILE_DEFAULT):
19341936
"""

0 commit comments

Comments
 (0)