diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index b21cb66153..a4629f5399 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -1501,7 +1501,7 @@ async def _execute( raise result if is_default_node: - self.replace_default_node() + client.replace_default_node() return [cmd.result for cmd in stack]