"Could not take out TTL lock" message was never logged (#502)

This is not a critical bug, because `attempt_to_acquire_leader` method was still returning False in this case.
This commit is contained in:
Alexander Kukushkin
2017-08-24 07:55:30 +02:00
committed by GitHub
parent 23152a7fc4
commit 4f87ea96ca
+4 -2
View File
@@ -245,12 +245,14 @@ class Consul(AbstractDCS):
return False
@catch_consul_errors
def _do_attempt_to_acquire_leader(self, kwargs):
return self.retry(self._client.kv.put, self.leader_path, self._name, **kwargs)
def attempt_to_acquire_leader(self, permanent=False):
if not self._session and not permanent:
self.refresh_session()
args = {} if permanent else {'acquire': self._session}
ret = self.retry(self._client.kv.put, self.leader_path, self._name, **args)
ret = self._do_attempt_to_acquire_leader({} if permanent else {'acquire': self._session})
if not ret:
logger.info('Could not take out TTL lock')
return ret