summaryrefslogtreecommitdiff
path: root/redis/cluster.py
diff options
context:
space:
mode:
authorAnas <anas.el.amraoui@live.com>2022-06-01 14:59:02 +0300
committerGitHub <noreply@github.com>2022-06-01 14:59:02 +0300
commitfa0be7671de6be85f859cbb57a31531b2482c9e1 (patch)
tree5470f36a4094e413f88480da35a3980ba73999bf /redis/cluster.py
parent05fc203f68c24fbd54c7b338b4610fa62972c326 (diff)
downloadredis-py-fa0be7671de6be85f859cbb57a31531b2482c9e1.tar.gz
Made sync lock consistent and added types to it (#2137)
* Made sync lock consistent and added types to it * Made linters happy * Fixed cluster client lock signature Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
Diffstat (limited to 'redis/cluster.py')
-rw-r--r--redis/cluster.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/redis/cluster.py b/redis/cluster.py
index a88792b..8e4c654 100644
--- a/redis/cluster.py
+++ b/redis/cluster.py
@@ -766,6 +766,7 @@ class RedisCluster(AbstractRedisCluster, RedisClusterCommands):
name,
timeout=None,
sleep=0.1,
+ blocking=True,
blocking_timeout=None,
lock_class=None,
thread_local=True,
@@ -781,6 +782,12 @@ class RedisCluster(AbstractRedisCluster, RedisClusterCommands):
when the lock is in blocking mode and another client is currently
holding the lock.
+ ``blocking`` indicates whether calling ``acquire`` should block until
+ the lock has been acquired or to fail immediately, causing ``acquire``
+ to return False and the lock not being acquired. Defaults to True.
+ Note this value can be overridden by passing a ``blocking``
+ argument to ``acquire``.
+
``blocking_timeout`` indicates the maximum amount of time in seconds to
spend trying to acquire the lock. A value of ``None`` indicates
continue trying forever. ``blocking_timeout`` can be specified as a
@@ -823,6 +830,7 @@ class RedisCluster(AbstractRedisCluster, RedisClusterCommands):
name,
timeout=timeout,
sleep=sleep,
+ blocking=blocking,
blocking_timeout=blocking_timeout,
thread_local=thread_local,
)