Skip to content

Commit 91bf1d1

Browse files
committed
Addressed review comment
1 parent 6ced889 commit 91bf1d1

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

hazelcast/internal/asyncio_connection.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,12 +70,12 @@ def __init__(self, initial_backoff, max_backoff, multiplier, cluster_connect_tim
7070

7171
def reset(self):
7272
self._attempt = 0
73-
self._cluster_connect_attempt_begin = time.time()
73+
self._cluster_connect_attempt_begin = asyncio.get_running_loop().time()
7474
self._current_backoff = min(self._max_backoff, self._initial_backoff)
7575

76-
def sleep(self):
76+
async def sleep(self):
7777
self._attempt += 1
78-
time_passed = time.time() - self._cluster_connect_attempt_begin
78+
time_passed = asyncio.get_running_loop().time() - self._cluster_connect_attempt_begin
7979
if time_passed > self._cluster_connect_timeout:
8080
_logger.warning(
8181
"Unable to get live cluster connection, cluster connect timeout (%s) is reached. "
@@ -98,7 +98,7 @@ def sleep(self):
9898
self._cluster_connect_timeout_text,
9999
self._max_backoff,
100100
)
101-
time.sleep(sleep_time)
101+
await asyncio.sleep(sleep_time)
102102
self._current_backoff = min(self._current_backoff * self._multiplier, self._max_backoff)
103103
return True
104104

@@ -547,7 +547,7 @@ async def _sync_connect_to_cluster(self):
547547
if not tried_addresses_per_attempt:
548548
self._check_client_active()
549549

550-
if not self._wait_strategy.sleep():
550+
if not await self._wait_strategy.sleep():
551551
break
552552
except (ClientNotAllowedInClusterError, InvalidConfigurationError):
553553
cluster_name = self._config.cluster_name

0 commit comments

Comments
 (0)