diff --git a/redis/cluster.py b/redis/cluster.py index 221df856c1..bf7ac2049b 100644 --- a/redis/cluster.py +++ b/redis/cluster.py @@ -867,7 +867,10 @@ def set_response_callback(self, command, callback): self.cluster_response_callbacks[command] = callback def _determine_nodes(self, *args, **kwargs): - command = args[0] + command = args[0].upper() + if len(args) >= 2 and f"{args[0]} {args[1]}".upper() in self.command_flags: + command = f"{args[0]} {args[1]}".upper() + nodes_flag = kwargs.pop("nodes_flag", None) if nodes_flag is not None: # nodes flag passed by the user