Skip to content

Commit d016d72

Browse files
committed
fix how async client is determined when getting raw access to the valkey client
1 parent 038d823 commit d016d72

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

CHANGES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ Version 0.3.0
88

99
### bug fix
1010
- fixed bug of `omit_exception` not handling generator and async generators
11+
- fixed bug of async `get_valkey_connection` checking if the client is async.
1112

1213
### internal change
1314
- moved all operations from `django_valkey.cache` and `django_valkey.async_cache.cache` to `django_valkey.base`.

django_valkey/async_cache/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
from inspect import isawaitable
1+
from inspect import iscoroutinefunction
22

33

44
async def get_valkey_connection(alias="default", write=True):
@@ -17,7 +17,7 @@ async def get_valkey_connection(alias="default", write=True):
1717
if not hasattr(cache.client, "get_client"):
1818
raise NotImplementedError(error_message)
1919

20-
if not isawaitable(cache.client.get_client):
20+
if not iscoroutinefunction(cache.client.get_client):
2121
raise "use django_valkey.get_valkey_connection for sync backends"
2222

2323
return await cache.client.get_client(write)

0 commit comments

Comments
 (0)