Made linters happy

Author: WisdomPill

docs/conf.py

@@ -55,7 +55,8 @@
 #
 # The short X.Y version.
 import redis
-version = '.'.join(redis.__version__.split(".")[0:2])
+
+version = ".".join(redis.__version__.split(".")[0:2])
 
 # The full version, including alpha/beta/rc tags.
 release = redis.__version__
@@ -108,13 +109,13 @@
 # further.  For a list of options available for each theme, see the
 # documentation.
 html_theme_options = {
-    'display_version': True,
-    'prev_next_buttons_location': 'bottom',
-    'style_external_links': False,
+    "display_version": True,
+    "prev_next_buttons_location": "bottom",
+    "style_external_links": False,
     # Toc options
-    'collapse_navigation': True,
-    'sticky_navigation': True,
-    'navigation_depth': 4,
+    "collapse_navigation": True,
+    "sticky_navigation": True,
+    "navigation_depth": 4,
 }
 
 # Add any paths that contain custom themes here, relative to this directory.
@@ -201,11 +202,7 @@
 # (source start file, target name, title, author, documentclass
 # [howto/manual]).
 latex_documents = [
-    ("index",
-        "redis-py.tex",
-        "redis-py Documentation",
-        "Redis Inc",
-        "manual"),
+    ("index", "redis-py.tex", "redis-py Documentation", "Redis Inc", "manual"),
 ]
 
 # The name of an image file (relative to this directory) to place at the top of
@@ -233,11 +230,7 @@
 
 # One entry per manual page. List of tuples
 # (source start file, name, description, authors, manual section).
-man_pages = [(
-    "index",
-    "redis-py",
-    "redis-py Documentation",
-    ["Andy McCurdy"], 1)]
+man_pages = [("index", "redis-py", "redis-py Documentation", ["Andy McCurdy"], 1)]
 
 # If true, show URL addresses after external links.
 # man_show_urls = False

redis/__init__.py

@@ -2,18 +2,11 @@
 from redis.cluster import RedisCluster
 from redis.connection import (
     BlockingConnectionPool,
-    ConnectionPool,
     Connection,
+    ConnectionPool,
     SSLConnection,
-    UnixDomainSocketConnection
-)
-from redis.sentinel import (
-    Sentinel,
-    SentinelConnectionPool,
-    SentinelManagedConnection,
-    SentinelManagedSSLConnection,
+    UnixDomainSocketConnection,
 )
-from redis.utils import from_url
 from redis.exceptions import (
     AuthenticationError,
     AuthenticationWrongNumberOfArgsError,
@@ -27,8 +20,15 @@
     RedisError,
     ResponseError,
     TimeoutError,
-    WatchError
+    WatchError,
+)
+from redis.sentinel import (
+    Sentinel,
+    SentinelConnectionPool,
+    SentinelManagedConnection,
+    SentinelManagedSSLConnection,
 )
+from redis.utils import from_url
 
 
 def int_or_str(value):
@@ -41,33 +41,33 @@ def int_or_str(value):
 __version__ = "4.1.0rc1"
 
 
-VERSION = tuple(map(int_or_str, __version__.split('.')))
+VERSION = tuple(map(int_or_str, __version__.split(".")))
 
 __all__ = [
-    'AuthenticationError',
-    'AuthenticationWrongNumberOfArgsError',
-    'BlockingConnectionPool',
-    'BusyLoadingError',
-    'ChildDeadlockedError',
-    'Connection',
-    'ConnectionError',
-    'ConnectionPool',
-    'DataError',
-    'from_url',
-    'InvalidResponse',
-    'PubSubError',
-    'ReadOnlyError',
-    'Redis',
-    'RedisCluster',
-    'RedisError',
-    'ResponseError',
-    'Sentinel',
-    'SentinelConnectionPool',
-    'SentinelManagedConnection',
-    'SentinelManagedSSLConnection',
-    'SSLConnection',
-    'StrictRedis',
-    'TimeoutError',
-    'UnixDomainSocketConnection',
-    'WatchError',
+    "AuthenticationError",
+    "AuthenticationWrongNumberOfArgsError",
+    "BlockingConnectionPool",
+    "BusyLoadingError",
+    "ChildDeadlockedError",
+    "Connection",
+    "ConnectionError",
+    "ConnectionPool",
+    "DataError",
+    "from_url",
+    "InvalidResponse",
+    "PubSubError",
+    "ReadOnlyError",
+    "Redis",
+    "RedisCluster",
+    "RedisError",
+    "ResponseError",
+    "Sentinel",
+    "SentinelConnectionPool",
+    "SentinelManagedConnection",
+    "SentinelManagedSSLConnection",
+    "SSLConnection",
+    "StrictRedis",
+    "TimeoutError",
+    "UnixDomainSocketConnection",
+    "WatchError",
 ]

redis/commands/__init__.py

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

redis/commands/helpers.py

@@ -22,7 +22,7 @@ def list_or_args(keys, args):
 def nativestr(x):
     """Return the decoded binary string, or a string, depending on type."""
     r = x.decode("utf-8", "replace") if isinstance(x, bytes) else x
-    if r == 'null':
+    if r == "null":
         return
     return r
 
@@ -58,14 +58,14 @@ def parse_list_to_dict(response):
     res = {}
     for i in range(0, len(response), 2):
         if isinstance(response[i], list):
-            res['Child iterators'].append(parse_list_to_dict(response[i]))
-        elif isinstance(response[i+1], list):
-            res['Child iterators'] = [parse_list_to_dict(response[i+1])]
+            res["Child iterators"].append(parse_list_to_dict(response[i]))
+        elif isinstance(response[i + 1], list):
+            res["Child iterators"] = [parse_list_to_dict(response[i + 1])]
         else:
             try:
-                res[response[i]] = float(response[i+1])
+                res[response[i]] = float(response[i + 1])
             except (TypeError, ValueError):
-                res[response[i]] = response[i+1]
+                res[response[i]] = response[i + 1]
     return res
 
 

redis/commands/search/commands.py

@@ -1,13 +1,13 @@
 import itertools
 import time
 
+from ..helpers import parse_to_dict
 from ._util import to_string
 from .aggregation import AggregateRequest, AggregateResult, Cursor
 from .document import Document
 from .query import Query
 from .result import Result
 from .suggestion import SuggestionParser
-from ..helpers import parse_to_dict
 
 NUMERIC = "NUMERIC"
 
@@ -453,7 +453,7 @@ def profile(self, query, limited=False):
         cmd = [PROFILE_CMD, self.index_name, ""]
         if limited:
             cmd.append("LIMITED")
-        cmd.append('QUERY')
+        cmd.append("QUERY")
 
         if isinstance(query, AggregateRequest):
             cmd[2] = "AGGREGATE"
@@ -462,19 +462,20 @@ def profile(self, query, limited=False):
             cmd[2] = "SEARCH"
             cmd += query.get_args()
         else:
-            raise ValueError("Must provide AggregateRequest object or "
-                             "Query object.")
+            raise ValueError("Must provide AggregateRequest object or " "Query object.")
 
         res = self.execute_command(*cmd)
 
         if isinstance(query, AggregateRequest):
             result = self._get_AggregateResult(res[0], query, query._cursor)
         else:
-            result = Result(res[0],
-                            not query._no_content,
-                            duration=(time.time() - st) * 1000.0,
-                            has_payload=query._with_payloads,
-                            with_scores=query._with_scores,)
+            result = Result(
+                res[0],
+                not query._no_content,
+                duration=(time.time() - st) * 1000.0,
+                has_payload=query._with_payloads,
+                with_scores=query._with_scores,
+            )
 
         return result, parse_to_dict(res[1])
 

redis/crc.py

@@ -4,10 +4,7 @@
 # For more information see: https://github.com/redis/redis/issues/2576
 REDIS_CLUSTER_HASH_SLOTS = 16384
 
-__all__ = [
-    "key_slot",
-    "REDIS_CLUSTER_HASH_SLOTS"
-]
+__all__ = ["key_slot", "REDIS_CLUSTER_HASH_SLOTS"]
 
 
 def key_slot(key, bucket=REDIS_CLUSTER_HASH_SLOTS):
@@ -20,5 +17,5 @@ def key_slot(key, bucket=REDIS_CLUSTER_HASH_SLOTS):
     if start > -1:
         end = key.find(b"}", start + 1)
         if end > -1 and end != start + 1:
-            key = key[start + 1: end]
+            key = key[start + 1 : end]
     return crc_hqx(key, 0) % bucket

redis/exceptions.py

@@ -91,6 +91,7 @@ class RedisClusterException(Exception):
     """
     Base exception for the RedisCluster client
     """
+
     pass
 
 
@@ -99,6 +100,7 @@ class ClusterError(RedisError):
     Cluster errors occurred multiple times, resulting in an exhaustion of the
     command execution TTL
     """
+
     pass
 
 
@@ -112,6 +114,7 @@ class ClusterDownError(ClusterError, ResponseError):
     unavailable. It automatically returns available as soon as all the slots
     are covered again.
     """
+
     def __init__(self, resp):
         self.args = (resp,)
         self.message = resp
@@ -136,8 +139,8 @@ def __init__(self, resp):
         """should only redirect to master node"""
         self.args = (resp,)
         self.message = resp
-        slot_id, new_node = resp.split(' ')
-        host, port = new_node.rsplit(':', 1)
+        slot_id, new_node = resp.split(" ")
+        host, port = new_node.rsplit(":", 1)
         self.slot_id = int(slot_id)
         self.node_addr = self.host, self.port = host, int(port)
 
@@ -148,6 +151,7 @@ class TryAgainError(ResponseError):
     Operations on keys that don't exist or are - during resharding - split
     between the source and destination nodes, will generate a -TRYAGAIN error.
     """
+
     def __init__(self, *args, **kwargs):
         pass
 
@@ -158,6 +162,7 @@ class ClusterCrossSlotError(ResponseError):
     A CROSSSLOT error is generated when keys in a request don't hash to the
     same slot.
     """
+
     message = "Keys in request don't hash to the same slot"
 
 
@@ -167,6 +172,7 @@ class MovedError(AskError):
     A request sent to a node that doesn't serve this key will be replayed with
     a MOVED error that points to the correct node.
     """
+
     pass
 
 
@@ -175,6 +181,7 @@ class MasterDownError(ClusterDownError):
     Error indicated MASTERDOWN error received from cluster.
     Link with MASTER is down and replica-serve-stale-data is set to 'no'.
     """
+
     pass
 
 
@@ -186,4 +193,5 @@ class SlotNotCoveredError(RedisClusterException):
     If this error is raised the client should drop the current node layout and
     attempt to reconnect and refresh the node layout again
     """
+
     pass

setup.py

@@ -1,5 +1,6 @@
 #!/usr/bin/env python
-from setuptools import setup, find_packages
+from setuptools import find_packages, setup
+
 import redis
 
 setup(
@@ -24,8 +25,8 @@
     author_email="[email protected]",
     python_requires=">=3.6",
     install_requires=[
-        'deprecated==1.2.3',
-        'packaging==21.3',
+        "deprecated==1.2.3",
+        "packaging==21.3",
     ],
     classifiers=[
         "Development Status :: 5 - Production/Stable",