fix linters

Signed-off-by: Mikhail Koviazin <github@mkmk.aleeas.com>

Author: mkmkme

tests/test_asyncio/test_commands.py

@@ -14,9 +14,7 @@
 
 import pytest
 import pytest_asyncio
-from valkey import __version__ as VALKEY_VERSION
 import valkey.asyncio as valkey
-from valkey.typing import KeyT, StreamIdT, StringTypeT
 from packaging.version import Version
 from tests.conftest import (
     assert_geo_is_close,
@@ -28,6 +26,7 @@
     skip_if_server_version_lt,
     skip_unless_arch_bits,
 )
+from valkey import __version__ as VALKEY_VERSION
 from valkey import exceptions
 from valkey._parsers.helpers import (
     _ValkeyCallbacks,
@@ -36,6 +35,7 @@
     parse_info,
 )
 from valkey.client import EMPTY_RESPONSE, NEVER_DECODE
+from valkey.typing import KeyT, StreamIdT, StringTypeT
 
 if sys.version_info >= (3, 11, 3):
     from asyncio import timeout as async_timeout
@@ -514,7 +514,9 @@ async def test_client_capa_redirect_on_replica(self, r: valkey.Valkey):
             info = await replica.info("replication")
             assert info["role"] in ("slave", "replica")
             expected_host = info["master_host"]
-            expected_port = int(info["master_port"])  # type: ignore[arg-type] # TODO: fix
+            expected_port = int(
+                info["master_port"]  # type: ignore[arg-type] # TODO: fix
+            )
 
             with pytest.raises(valkey.RedirectError) as exc_get:
                 await replica.get(key)
@@ -566,10 +568,16 @@ async def test_config_get(self, r: valkey.Valkey):
     @pytest.mark.onlynoncluster
     async def test_config_resetstat(self, r: valkey.Valkey):
         await r.ping()
-        prior_commands_processed = int((await r.info())["total_commands_processed"])  # type: ignore[arg-type] # TODO: fix
+        # TODO: fix
+        prior_commands_processed = int(
+            (await r.info())["total_commands_processed"]  # type: ignore[arg-type]
+        )
         assert prior_commands_processed >= 1
         await r.config_resetstat()
-        reset_commands_processed = int((await r.info())["total_commands_processed"])  # type: ignore[arg-type] # TODO: fix
+        # TODO: fix
+        reset_commands_processed = int(
+            (await r.info())["total_commands_processed"]  # type: ignore[arg-type]
+        )
         assert reset_commands_processed < prior_commands_processed
 
     async def test_config_set(self, r: valkey.Valkey):

valkey/asyncio/client.py

@@ -13,6 +13,7 @@
     Dict,
     Iterable,
     List,
+    Literal,
     Mapping,
     MutableMapping,
     Optional,
@@ -25,7 +26,6 @@
     Union,
     cast,
 )
-from typing import Literal
 
 from valkey._cache import (
     DEFAULT_ALLOW_LIST,

valkey/asyncio/cluster.py

@@ -11,14 +11,14 @@
     Dict,
     Generator,
     List,
+    Literal,
     Mapping,
     Optional,
     Tuple,
     Type,
     TypeVar,
     Union,
 )
-from typing import Literal
 
 from valkey._cache import (
     DEFAULT_ALLOW_LIST,

valkey/commands/core.py

@@ -16,7 +16,6 @@
     Literal,
     Mapping,
     NoReturn,
-    Optional,
     Sequence,
     TypeVar,
     Union,
@@ -31,16 +30,18 @@
     AnyEncodableT,
     AnyFieldT,
     AnyKeyT,
-    AnyStreamIdT,
     AsyncClientProtocol,
     BitfieldOffsetT,
     BlockingPopResult,
+    BZPopResultT,
     ChannelT,
     CommandsProtocol,
     ConsumerT,
     EncodableT,
     ExpiryT,
     FieldT,
+    FunctionListEntryT,
+    FunctionStatsT,
     GeoSearchReplyT,
     GroupT,
     InfoData,
@@ -49,8 +50,6 @@
     LCSIdxData,
     MemoryStatsData,
     PatternT,
-    FunctionListEntryT,
-    FunctionStatsT,
     ResponseT,
     ScriptTextT,
     StreamEntryT,
@@ -59,10 +58,9 @@
     StreamReadResp3T,
     StringTypeT,
     SyncClientProtocol,
-    BZPopResultT,
     TimeoutSecT,
-    XPendingResult,
     XPendingRangeEntry,
+    XPendingResult,
     ZMPopResultT,
     ZPopResultT,
     ZScoreBoundT,
@@ -8490,7 +8488,9 @@ def zrange(
         # Need to support ``desc`` also when using old redis version
         # because it was supported in 3.5.3 (of redis-py)
         if not byscore and not bylex and (offset is None and num is None) and desc:
-            return self.zrevrange(name, start, end, withscores, score_cast_func)  # type: ignore[misc]
+            return self.zrevrange(  # type: ignore[misc]
+                name, start, end, withscores, score_cast_func
+            )
 
         return self._zrange(
             "ZRANGE",