File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
django_valkey/async_cache Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ class AsyncConnectionFactory(BaseConnectionFactory[AValkey, ConnectionPool]):
16
16
path_pool_cls = "valkey.asyncio.connection.ConnectionPool"
17
17
path_base_cls = "valkey.asyncio.client.Valkey"
18
18
19
- async def disconnect (self , connection : type [AValkey ] | type ) -> None :
19
+ async def disconnect (self , connection : type [AValkey ]) -> None :
20
20
await connection .connection_pool .disconnect ()
21
21
22
22
def get_parser_cls (self ) -> type [DefaultParser ] | type :
@@ -57,11 +57,11 @@ def __init__(self, options: dict):
57
57
** connection_kwargs ,
58
58
)
59
59
60
- async def get_connection_pool (self , params : dict ) -> ConnectionPool | Any :
60
+ def get_connection_pool (self , params : dict ) -> ConnectionPool | Any :
61
61
url = urlparse (params ["url" ])
62
62
cp_params = params
63
63
cp_params .update (service_name = url .hostname , sentinel_manager = self ._sentinel )
64
- pool = await super ().get_connection_pool (cp_params )
64
+ pool = super ().get_connection_pool (cp_params )
65
65
66
66
is_master = parse_qs (url .query ).get ("is_master" )
67
67
if is_master :
You can’t perform that action at this time.
0 commit comments