linter checks

Author: Shubham Kaudewar

redis/cache.py

@@ -28,6 +28,7 @@ class CacheKey:
             when commands have the same keys but different arguments.
             Changing this field will affect cache key uniqueness.
     """
+
     command: str
     redis_keys: tuple
     redis_args: tuple = ()  # Additional arguments for the Redis command; affects cache key uniqueness.

redis/connection.py

@@ -1214,7 +1214,9 @@ def send_command(self, *args, **kwargs):
         with self._cache_lock:
             # Command is write command or not allowed
             # to be cached.
-            if not self._cache.is_cachable(CacheKey(command=args[0], redis_keys=(), redis_args=())):
+            if not self._cache.is_cachable(
+                CacheKey(command=args[0], redis_keys=(), redis_args=())
+            ):
                 self._current_command_cache_key = None
                 self._conn.send_command(*args, **kwargs)
                 return

tests/test_connection.py

@@ -357,7 +357,7 @@ def test_network_connection_failure():
 
 @pytest.mark.skipif(
     not hasattr(socket, "AF_UNIX"),
-    reason="Unix domain sockets not supported on this platform"
+    reason="Unix domain sockets not supported on this platform",
 )
 def test_unix_socket_connection_failure():
     exp_err = "Error 2 connecting to unix:///tmp/a.sock. No such file or directory."
@@ -468,25 +468,33 @@ def test_read_response_returns_cached_reply(self, mock_cache, mock_connection):
             None,
             None,
             CacheEntry(
-                cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                cache_key=CacheKey(
+                    command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                ),
                 cache_value=CacheProxyConnection.DUMMY_CACHE_VALUE,
                 status=CacheEntryStatus.IN_PROGRESS,
                 connection_ref=mock_connection,
             ),
             CacheEntry(
-                cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                cache_key=CacheKey(
+                    command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                ),
                 cache_value=b"bar",
                 status=CacheEntryStatus.VALID,
                 connection_ref=mock_connection,
             ),
             CacheEntry(
-                cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                cache_key=CacheKey(
+                    command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                ),
                 cache_value=b"bar",
                 status=CacheEntryStatus.VALID,
                 connection_ref=mock_connection,
             ),
             CacheEntry(
-                cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                cache_key=CacheKey(
+                    command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                ),
                 cache_value=b"bar",
                 status=CacheEntryStatus.VALID,
                 connection_ref=mock_connection,
@@ -508,15 +516,23 @@ def test_read_response_returns_cached_reply(self, mock_cache, mock_connection):
             [
                 call(
                     CacheEntry(
-                        cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                        cache_key=CacheKey(
+                            command="GET",
+                            redis_keys=("foo",),
+                            redis_args=("GET", "foo"),
+                        ),
                         cache_value=CacheProxyConnection.DUMMY_CACHE_VALUE,
                         status=CacheEntryStatus.IN_PROGRESS,
                         connection_ref=mock_connection,
                     )
                 ),
                 call(
                     CacheEntry(
-                        cache_key=CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo")),
+                        cache_key=CacheKey(
+                            command="GET",
+                            redis_keys=("foo",),
+                            redis_args=("GET", "foo"),
+                        ),
                         cache_value=b"bar",
                         status=CacheEntryStatus.VALID,
                         connection_ref=mock_connection,
@@ -527,9 +543,21 @@ def test_read_response_returns_cached_reply(self, mock_cache, mock_connection):
 
         mock_cache.get.assert_has_calls(
             [
-                call(CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo"))),
-                call(CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo"))),
-                call(CacheKey(command="GET", redis_keys=("foo",), redis_args=("GET", "foo"))),
+                call(
+                    CacheKey(
+                        command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                    )
+                ),
+                call(
+                    CacheKey(
+                        command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                    )
+                ),
+                call(
+                    CacheKey(
+                        command="GET", redis_keys=("foo",), redis_args=("GET", "foo")
+                    )
+                ),
             ]
         )