black/ruff

Author: amirreza8002

django_valkey/async_cache/client/default.py

@@ -19,7 +19,10 @@
 
 if TYPE_CHECKING:
     from django_valkey.async_cache.cache import AsyncValkeyCache
-    from django_valkey.async_cache.pool import AsyncConnectionFactory, AsyncSentinelConnectionFactory
+    from django_valkey.async_cache.pool import (
+        AsyncConnectionFactory,
+        AsyncSentinelConnectionFactory,
+    )
 
 
 async def glove_escape(s: str) -> str:
@@ -56,7 +59,9 @@ def __init__(
             "DJANGO_VALKEY_CONNECTION_FACTORY",
             "django_valkey.async_cache.pool.AsyncConnectionFactory",
         )
-        self.connection_factory: AsyncConnectionFactory | AsyncSentinelConnectionFactory | Any = pool.get_connection_factory(
+        self.connection_factory: (
+            AsyncConnectionFactory | AsyncSentinelConnectionFactory | Any
+        ) = pool.get_connection_factory(
             options=self._options, path=self._connection_factory
         )
 

django_valkey/async_cache/pool.py

@@ -9,7 +9,7 @@
 from valkey.asyncio.sentinel import Sentinel
 from valkey._parsers.url_parser import to_bool
 
-from django_valkey.base_pool import BaseConnectionPool, Base, Pool
+from django_valkey.base_pool import BaseConnectionPool
 
 
 class AsyncConnectionFactory(BaseConnectionPool[AValkey, ConnectionPool]):
@@ -31,8 +31,9 @@ async def connect(self, url: str) -> AValkey | Any:
 
     async def get_connection(self, params: dict) -> AValkey | Any:
         pool = self.get_or_create_connection_pool(params)
-        return await self.base_client_cls(connection_pool=pool, **self.base_client_cls_kwargs)
-
+        return await self.base_client_cls(
+            connection_pool=pool, **self.base_client_cls_kwargs
+        )
 
 
 class AsyncSentinelConnectionFactory(AsyncConnectionFactory):

django_valkey/pool.py

@@ -30,14 +30,15 @@ def get_parser_cls(self) -> type[DefaultParser] | type:
             return DefaultParser
         return import_string(cls)
 
-    def connect(self, url :str) -> Valkey | Any:
+    def connect(self, url: str) -> Valkey | Any:
         params = self.make_connection_params(url)
         return self.get_connection(params)
 
     def get_connection(self, params: dict) -> Base | Any:
         pool = self.get_or_create_connection_pool(params)
         return self.base_client_cls(connection_pool=pool, **self.base_client_cls_kwargs)
 
+
 class SentinelConnectionFactory(ConnectionFactory):
     def __init__(self, options: dict):
         # allow overriding the default SentinelConnectionPool class