2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-16 20:57:53 +00:00

Fix not having currentleader set

A slave node now recognizes itself as such.
This commit is contained in:
Jarrod Johnson 2018-05-11 15:00:18 -04:00
parent 3cc9ee1a17
commit aa2be98dc3

View File

@ -79,6 +79,7 @@ def connect_to_leader(cert=None, name=None, leader=None):
cfm.set_global(globvar, globaldata[globvar])
cfm.ConfigManager(tenant=None)._load_from_json(dbjson)
cfm.ConfigManager._bg_sync_to_file()
currentleader = leader
cfm.follow_channel(remote)
def get_myname():