From a4ed092ae1f6b5bd79b7bca3071e14e251ac64ab Mon Sep 17 00:00:00 2001
From: Mykhailo Shchurov <mykhailo.shchurov@wolt.com>
Date: Tue, 15 Feb 2022 00:18:32 +0200
Subject: [PATCH] Reuse CommandsParser from RedisCluster in ClusterPipeline

---
 redis/cluster.py | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/redis/cluster.py b/redis/cluster.py
index b594d3084a..7151cfebce 100644
--- a/redis/cluster.py
+++ b/redis/cluster.py
@@ -712,6 +712,7 @@ def pipeline(self, transaction=None, shard_hint=None):
 
         return ClusterPipeline(
             nodes_manager=self.nodes_manager,
+            commands_parser=self.commands_parser,
             startup_nodes=self.nodes_manager.startup_nodes,
             result_callbacks=self.result_callbacks,
             cluster_response_callbacks=self.cluster_response_callbacks,
@@ -1598,6 +1599,7 @@ class ClusterPipeline(RedisCluster):
     def __init__(
         self,
         nodes_manager,
+        commands_parser,
         result_callbacks=None,
         cluster_response_callbacks=None,
         startup_nodes=None,
@@ -1610,6 +1612,7 @@ def __init__(
         log.info("Creating new instance of ClusterPipeline")
         self.command_stack = []
         self.nodes_manager = nodes_manager
+        self.commands_parser = commands_parser
         self.refresh_table_asap = False
         self.result_callbacks = (
             result_callbacks or self.__class__.RESULT_CALLBACKS.copy()
@@ -1627,11 +1630,6 @@ def __init__(
             kwargs.get("decode_responses", False),
         )
 
-        # The commands parser refers to the parent
-        # so that we don't push the COMMAND command
-        # onto the stack
-        self.commands_parser = CommandsParser(super())
-
     def __repr__(self):
         """ """
         return f"{type(self).__name__}"