Skip to content

Commit 534829e

Browse files
committed
define _connect_to_sentinel in async server
1 parent eacbd70 commit 534829e

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

redis/asyncio/sentinel.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,9 @@ async def _connect_retry(self):
7373
if self._is_address_fixed:
7474
self.connect_to(self.host, self.port)
7575
return
76+
await self._connect_to_sentinel()
77+
78+
async def _connect_to_sentinel(self):
7679
# If same_server is False, connnect to master in master mode
7780
# and rotate to the next slave in slave mode
7881
if self.connection_pool.is_master:

0 commit comments

Comments
 (0)