self.cluster = None if unexpected exception occured

2026-08-25 14:53:37 +00:00 · 2015-09-16 15:14:02 +02:00
parent a8305079c3
commit 0435e36cad
1 changed files with 1 additions and 0 deletions
@@ -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')