Ensure zk_listener is readded after reconnect

This commit is contained in:
Joshua Boniface 2020-08-11 12:46:15 -04:00
parent 099c58ead8
commit e0cb4a58c3
1 changed files with 3 additions and 0 deletions

View File

@ -538,7 +538,10 @@ def zk_listener(state):
del _zk_conn del _zk_conn
continue continue
# Overwrite global zk_conn with new connection
zk_conn = _zk_conn zk_conn = _zk_conn
# Readd the listener
zk_conn.add_listener(zk_listener)
break break
zk_conn.add_listener(zk_listener) zk_conn.add_listener(zk_listener)