diff options
| author | suxb201 <suxb201@gmail.com> | 2022-04-28 14:17:31 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-04-28 09:17:31 +0300 |
| commit | abd5aeffc5cca02826973ab32e4d43e200eff18e (patch) | |
| tree | 9f4a6a1f0ecd839eb3d322872d093a2b7041e3cf /redis/cluster.py | |
| parent | 9e7e9733de7db3c68bdfd142ff94c63f27bf6bdf (diff) | |
| download | redis-py-abd5aeffc5cca02826973ab32e4d43e200eff18e.tar.gz | |
fix execute_command() determine nodes error when no key command (#2097)
Diffstat (limited to 'redis/cluster.py')
| -rw-r--r-- | redis/cluster.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/redis/cluster.py b/redis/cluster.py index 221df85..bf7ac20 100644 --- a/redis/cluster.py +++ b/redis/cluster.py @@ -867,7 +867,10 @@ class RedisCluster(RedisClusterCommands): 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 |