Merge pull request #4 from amirreza8002/lock

added blocking and lock_class to get_lock

Author: amirreza8002

CHANGES.rst

@@ -1,3 +1,8 @@
+Version 0.1.6
+-------------
+
+- added ``blocking`` and ``lock_class`` to get_lock parameters.
+
 Version 0.1.5
 -------------
 

django_valkey/__init__.py

@@ -1,4 +1,4 @@
-VERSION = (0, 1, 5)
+VERSION = (0, 1, 6)
 __version__ = ".".join(map(str, VERSION))
 
 

django_valkey/async_cache/client/default.py

@@ -294,8 +294,10 @@ async def get_lock(
         version: int | None = None,
         timeout: float | int | None = None,
         sleep: float = 0.1,
+        blocking: bool = True,
         blocking_timeout: float | None = None,
         client: AValkey | Any | None = None,
+        lock_class=None,
         thread_local: bool = True,
     ) -> "Lock":
         """Returns a Lock object, the object then should be used in an async context manager"""
@@ -308,7 +310,9 @@ async def get_lock(
             key,
             timeout=timeout,
             sleep=sleep,
+            blocking=blocking,
             blocking_timeout=blocking_timeout,
+            lock_class=lock_class,
             thread_local=thread_local,
         )
 

django_valkey/base_client.py

@@ -423,8 +423,10 @@ def get_lock(
         version: int | None = None,
         timeout: float | None = None,
         sleep: float = 0.1,
+        blocking: bool = True,
         blocking_timeout: float | None = None,
         client: Backend | Any | None = None,
+        lock_class=None,
         thread_local: bool = True,
     ) -> "Lock":
         client = self._get_client(write=True, client=client)
@@ -434,7 +436,9 @@ def get_lock(
             key,
             timeout=timeout,
             sleep=sleep,
+            blocking=blocking,
             blocking_timeout=blocking_timeout,
+            lock_class=lock_class,
             thread_local=thread_local,
         )
 

django_valkey/client/sharded.py

@@ -283,8 +283,10 @@ def get_lock(
         version=None,
         timeout=None,
         sleep=0.1,
+        blocking: bool = True,
         blocking_timeout=None,
         client=None,
+        lock_class=None,
         thread_local=True,
     ):
         if client is None:
@@ -295,8 +297,10 @@ def get_lock(
             key,
             timeout=timeout,
             sleep=sleep,
+            blocking=blocking,
             client=client,
             blocking_timeout=blocking_timeout,
+            lock_class=lock_class,
             thread_local=thread_local,
         )
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "django-valkey"
-version = "0.1.5"
+version = "0.1.6"
 license = "BSD-3-Caluse"
 description = "a valkey cache and session backend for django"
 authors = ["amirreza <[email protected]>"]