Fixed async clusterPipeline default node replacement

redis · Nov 28, 2022 · 4cfa069 · 4cfa069
1 parent 484861e
commit 4cfa069
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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]