I do have to restart Kazoo during the SUSPENDED fail
This commit is contained in:
parent
6b5fa3d50b
commit
2cdd98d0f1
|
@ -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)
|
||||
|
|
Loading…
Reference in New Issue