Do not try to query xlog_location when async_executor is busy

2026-08-25 14:53:37 +00:00 · 2016-04-13 13:32:39 +02:00
parent 01da5266a0
commit 946d8ef4f2
1 changed files with 1 additions and 1 deletions
@@ -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: