2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-09 13:05:49 +00:00

Try to reestablish collective on leader loss

This commit is contained in:
Jarrod Johnson 2018-06-25 10:40:29 -04:00
parent f301cd272f
commit 0499a14fe8

View File

@ -86,6 +86,8 @@ def connect_to_leader(cert=None, name=None, leader=None):
cfm.ConfigManager._bg_sync_to_file()
currentleader = leader
cfm.follow_channel(remote)
# The leader has folded, time to startup again...
eventlet.spawn_n(start_collective)
def get_myname():
try: