From de8144f1a60e924b150482bf31a625fe4dbe9abe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Adam=20=C5=BDurek?= Date: Sun, 14 Jan 2024 21:03:20 +0100 Subject: [PATCH] asyncio redis cluster: fixed reconnection when whole cluster goes down and then back online --- redis/asyncio/cluster.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index 719c2d2283..ef2eacfa46 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -1144,6 +1144,7 @@ class NodesManager: "require_full_coverage", "slots_cache", "startup_nodes", + "_initial_startup_nodes", "address_remap", ) @@ -1155,6 +1156,7 @@ def __init__( address_remap: Optional[Callable[[Tuple[str, int]], Tuple[str, int]]] = None, ) -> None: self.startup_nodes = {node.name: node for node in startup_nodes} + self._initial_startup_nodes = copy.deepcopy(startup_nodes) self.require_full_coverage = require_full_coverage self.connection_kwargs = connection_kwargs self.address_remap = address_remap @@ -1277,7 +1279,7 @@ async def initialize(self) -> None: startup_nodes_reachable = False fully_covered = False exception = None - for startup_node in self.startup_nodes.values(): + for startup_node in self.startup_nodes.values() or self._initial_startup_nodes.values(): try: # Make sure cluster mode is enabled on this node try: