Reformatted files with black

Author: barshaul

redis/cluster.py

@@ -7,10 +7,7 @@
 import time
 from collections import OrderedDict
 from redis.client import CaseInsensitiveDict, Redis, PubSub
-from redis.commands import (
-    RedisClusterCommands,
-    CommandsParser
-)
+from redis.commands import RedisClusterCommands, CommandsParser
 from redis.connection import DefaultParser, ConnectionPool, Encoder, parse_url
 from redis.crc import key_slot, REDIS_CLUSTER_HASH_SLOTS
 from redis.exceptions import (
@@ -674,8 +671,8 @@ def monitor(self, target_node=None):
             target_node = self.get_default_node()
         if target_node.redis_connection is None:
             raise RedisClusterException(
-                "Cluster Node {0} has no redis_connection".
-                format(target_node.name))
+                "Cluster Node {0} has no redis_connection".format(target_node.name)
+            )
         return target_node.redis_connection.monitor()
 
     def pubsub(self, node=None, host=None, port=None, **kwargs):

redis/commands/__init__.py

@@ -6,10 +6,10 @@
 from .sentinel import SentinelCommands
 
 __all__ = [
-    'RedisClusterCommands',
-    'CommandsParser',
-    'CoreCommands',
-    'list_or_args',
-    'RedisModuleCommands',
-    'SentinelCommands'
+    "RedisClusterCommands",
+    "CommandsParser",
+    "CoreCommands",
+    "list_or_args",
+    "RedisModuleCommands",
+    "SentinelCommands",
 ]

redis/commands/cluster.py

@@ -3,12 +3,7 @@
     RedisError,
 )
 from redis.crc import key_slot
-from .core import (
-    ACLCommands,
-    DataAccessCommands,
-    ManagementCommands,
-    PubSubCommands
-)
+from .core import ACLCommands, DataAccessCommands, ManagementCommands, PubSubCommands
 from .helpers import list_or_args
 
 
@@ -158,16 +153,15 @@ class ClusterManagementCommands(ManagementCommands):
     The class inherits from Redis's core ManagementCommands class and do the
     required adjustments to work with cluster mode
     """
+
     def slaveof(self, *args, **kwargs):
         raise RedisClusterException("SLAVEOF is not supported in cluster mode")
 
     def replicaof(self, *args, **kwargs):
-        raise RedisClusterException("REPLICAOF is not supported in cluster"
-                                    " mode")
+        raise RedisClusterException("REPLICAOF is not supported in cluster" " mode")
 
     def swapdb(self, *args, **kwargs):
-        raise RedisClusterException("SWAPDB is not supported in cluster"
-                                    " mode")
+        raise RedisClusterException("SWAPDB is not supported in cluster" " mode")
 
 
 class ClusterDataAccessCommands(DataAccessCommands):
@@ -177,20 +171,43 @@ class ClusterDataAccessCommands(DataAccessCommands):
     The class inherits from Redis's core DataAccessCommand class and do the
     required adjustments to work with cluster mode
     """
-    def stralgo(self, algo, value1, value2, specific_argument='strings',
-                len=False, idx=False, minmatchlen=None, withmatchlen=False,
-                **kwargs):
-        target_nodes = kwargs.pop('target_nodes', None)
-        if specific_argument == 'strings' and target_nodes is None:
-            target_nodes = 'default-node'
-        kwargs.update({'target_nodes': target_nodes})
-        return super().stralgo(algo, value1, value2, specific_argument,
-                               len, idx, minmatchlen, withmatchlen, **kwargs)
-
-
-class RedisClusterCommands(ClusterMultiKeyCommands, ClusterManagementCommands,
-                           ACLCommands, PubSubCommands,
-                           ClusterDataAccessCommands):
+
+    def stralgo(
+        self,
+        algo,
+        value1,
+        value2,
+        specific_argument="strings",
+        len=False,
+        idx=False,
+        minmatchlen=None,
+        withmatchlen=False,
+        **kwargs,
+    ):
+        target_nodes = kwargs.pop("target_nodes", None)
+        if specific_argument == "strings" and target_nodes is None:
+            target_nodes = "default-node"
+        kwargs.update({"target_nodes": target_nodes})
+        return super().stralgo(
+            algo,
+            value1,
+            value2,
+            specific_argument,
+            len,
+            idx,
+            minmatchlen,
+            withmatchlen,
+            **kwargs,
+        )
+
+
+class RedisClusterCommands(
+    ClusterMultiKeyCommands,
+    ClusterManagementCommands,
+    ACLCommands,
+    PubSubCommands,
+    ClusterDataAccessCommands,
+):
     """
     A class for all Redis Cluster commands