diff --git a/patroni/ha.py b/patroni/ha.py index 7cdecd02..6923a126 100644 --- a/patroni/ha.py +++ b/patroni/ha.py @@ -38,7 +38,7 @@ class Ha(object): def update_lock(self): ret = self.dcs.update_leader() - if ret: + if ret and not self._async_executor.busy: try: self.dcs.write_leader_optime(self.state_handler.last_operation()) except: