Skip to content

Commit e8abd46

Browse files
committed
fixed get_lock's parameters
1 parent 08796d0 commit e8abd46

File tree

3 files changed

+12
-0
lines changed

3 files changed

+12
-0
lines changed

django_valkey/async_cache/client/default.py

+4
Original file line numberDiff line numberDiff line change
@@ -294,8 +294,10 @@ async def get_lock(
294294
version: int | None = None,
295295
timeout: float | int | None = None,
296296
sleep: float = 0.1,
297+
blocking: bool = True,
297298
blocking_timeout: float | None = None,
298299
client: AValkey | Any | None = None,
300+
lock_class=None,
299301
thread_local: bool = True,
300302
) -> "Lock":
301303
"""Returns a Lock object, the object then should be used in an async context manager"""
@@ -308,7 +310,9 @@ async def get_lock(
308310
key,
309311
timeout=timeout,
310312
sleep=sleep,
313+
blocking=blocking,
311314
blocking_timeout=blocking_timeout,
315+
lock_class=lock_class,
312316
thread_local=thread_local,
313317
)
314318

django_valkey/base_client.py

+4
Original file line numberDiff line numberDiff line change
@@ -423,8 +423,10 @@ def get_lock(
423423
version: int | None = None,
424424
timeout: float | None = None,
425425
sleep: float = 0.1,
426+
blocking: bool = True,
426427
blocking_timeout: float | None = None,
427428
client: Backend | Any | None = None,
429+
lock_class=None,
428430
thread_local: bool = True,
429431
) -> "Lock":
430432
client = self._get_client(write=True, client=client)
@@ -434,7 +436,9 @@ def get_lock(
434436
key,
435437
timeout=timeout,
436438
sleep=sleep,
439+
blocking=blocking,
437440
blocking_timeout=blocking_timeout,
441+
lock_class=lock_class,
438442
thread_local=thread_local,
439443
)
440444

django_valkey/client/sharded.py

+4
Original file line numberDiff line numberDiff line change
@@ -283,8 +283,10 @@ def get_lock(
283283
version=None,
284284
timeout=None,
285285
sleep=0.1,
286+
blocking: bool = True,
286287
blocking_timeout=None,
287288
client=None,
289+
lock_class=None,
288290
thread_local=True,
289291
):
290292
if client is None:
@@ -295,8 +297,10 @@ def get_lock(
295297
key,
296298
timeout=timeout,
297299
sleep=sleep,
300+
blocking=blocking,
298301
client=client,
299302
blocking_timeout=blocking_timeout,
303+
lock_class=lock_class,
300304
thread_local=thread_local,
301305
)
302306

0 commit comments

Comments
 (0)