mirror of
https://github.com/xcat2/confluent.git
synced 2025-08-27 21:40:51 +00:00
Declare ready on becoming leader
Provide for leader scenario to correctly flag configmanager as ready.
This commit is contained in:
@@ -716,6 +716,7 @@ def become_leader(connection):
|
||||
if reassimilate is not None:
|
||||
reassimilate.kill()
|
||||
reassimilate = eventlet.spawn(reassimilate_missing)
|
||||
cfm._ready = True
|
||||
if _assimilate_missing(skipaddr):
|
||||
schedule_rebalance()
|
||||
|
||||
|
Reference in New Issue
Block a user