@@ -888,7 +888,7 @@ def determine_slot(self, *args):
888888 if len (args ) <= 2 :
889889 raise RedisClusterException (f"Invalid args in command: { args } " )
890890 num_actual_keys = args [2 ]
891- eval_keys = args [3 : 3 + num_actual_keys ]
891+ eval_keys = args [3 : 3 + num_actual_keys ]
892892 # if there are 0 keys, that means the script can be run on any node
893893 # so we can just return a random slot
894894 if len (eval_keys ) == 0 :
@@ -1908,14 +1908,16 @@ def _send_cluster_commands(
19081908 target_nodes = self ._parse_target_nodes (passed_targets )
19091909 else :
19101910 target_nodes = self ._determine_nodes (
1911- * c .args , node_flag = passed_targets )
1911+ * c .args , node_flag = passed_targets
1912+ )
19121913 if not target_nodes :
19131914 raise RedisClusterException (
19141915 f"No targets were found to execute { c .args } command on"
19151916 )
19161917 if len (target_nodes ) > 1 :
19171918 raise RedisClusterException (
1918- f"Too many targets for command { c .args } " )
1919+ f"Too many targets for command { c .args } "
1920+ )
19191921
19201922 node = target_nodes [0 ]
19211923
@@ -1938,7 +1940,7 @@ def _send_cluster_commands(
19381940 nodes [node_name ] = NodeCommands (
19391941 redis_node .parse_response ,
19401942 redis_node .connection_pool ,
1941- connection
1943+ connection ,
19421944 )
19431945 nodes [node_name ].append (c )
19441946 break
0 commit comments