diff --git a/patroni/ha.py b/patroni/ha.py index 0bd2747a..c0821bc2 100644 --- a/patroni/ha.py +++ b/patroni/ha.py @@ -307,7 +307,8 @@ class Ha(object): if self._rewind.can_rewind: # rewind is required, but postgres wasn't shut down cleanly. - if self.state_handler.controldata().get('Database cluster state') == 'in archive recovery': + if not self.state_handler.is_running() and \ + self.state_handler.controldata().get('Database cluster state') == 'in archive recovery': msg = self._handle_crash_recovery() if msg: return msg