diff --git a/patroni/zookeeper.py b/patroni/zookeeper.py index eae810ed..bc16a8ea 100644 --- a/patroni/zookeeper.py +++ b/patroni/zookeeper.py @@ -170,6 +170,7 @@ class ZooKeeper(AbstractDCS): try: self.client.retry(self._inner_load_cluster) except: + self.cluster = None logger.exception('get_cluster') self.session_listener(KazooState.LOST) raise ZooKeeperError('ZooKeeper in not responding properly')