mirror of
https://github.com/outbackdingo/patroni.git
synced 2026-08-25 14:53:37 +00:00
Return True after success call of update_leader and check return code
This commit is contained in:
@@ -86,6 +86,7 @@ class Etcd:
|
||||
def update_leader(self, value):
|
||||
try:
|
||||
self.put_client_path("/leader", {"value": value, "ttl": self.ttl, "prevValue": value})
|
||||
return True
|
||||
except urllib2.HTTPError:
|
||||
logger.error("Error updating TTL on ETCD for primary.")
|
||||
return False
|
||||
|
||||
+1
-1
@@ -59,7 +59,7 @@ class Ha:
|
||||
self.state_handler.follow_the_leader(self.fetch_current_leader())
|
||||
return "following a different leader because i am not the healthiest node"
|
||||
else:
|
||||
if self.has_lock() and self.update_lock()
|
||||
if self.has_lock() and self.update_lock():
|
||||
if not self.state_handler.is_leader():
|
||||
self.state_handler.promote()
|
||||
return "promoted self to leader because i had the session lock"
|
||||
|
||||
Reference in New Issue
Block a user