diff --git a/node-daemon/pvcd/Daemon.py b/node-daemon/pvcd/Daemon.py index 275e8372..1d9dd361 100644 --- a/node-daemon/pvcd/Daemon.py +++ b/node-daemon/pvcd/Daemon.py @@ -294,8 +294,10 @@ def zk_listener(state): stopKeepaliveTimer() while True: + _zk_conn = kazoo.client.KazooClient(hosts=config['coordinators']) try: - zk_conn.start() + _zk_conn.start() + zk_conn = _zk_conn break except: time.sleep(1)