diff --git a/tooz/drivers/redis.py b/tooz/drivers/redis.py index f7ae2209..7a55af46 100644 --- a/tooz/drivers/redis.py +++ b/tooz/drivers/redis.py @@ -88,7 +88,8 @@ class RedisLock(locking.Lock): acquired = self._lock.acquire( blocking=blocking, blocking_timeout=timeout) if acquired: - self._coord._acquired_locks.add(self) + with self._exclusive_access: + self._coord._acquired_locks.add(self) return acquired def release(self):