Merge "redis: always remove lock from acquired lock when release()ing"
This commit is contained in:
commit
29ec8eb26a
@ -102,7 +102,8 @@ class RedisLock(locking.Lock):
|
||||
except exceptions.LockError as e:
|
||||
LOG.error("Unable to release lock '%r': %s", self, e)
|
||||
return False
|
||||
self._coord._acquired_locks.discard(self)
|
||||
finally:
|
||||
self._coord._acquired_locks.discard(self)
|
||||
return True
|
||||
|
||||
def heartbeat(self):
|
||||
|
Loading…
x
Reference in New Issue
Block a user