From 4cfa069165e6e921ff94dd0b07497d27f34c044e Mon Sep 17 00:00:00 2001
From: Bar Shaul <barshaul@amazon.com>
Date: Mon, 28 Nov 2022 13:29:39 +0200
Subject: [PATCH] Fixed async clusterPipeline default node replacement

---
 redis/asyncio/cluster.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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]