2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 17:43:14 +00:00

Have follower thread avoid killing self

This commit is contained in:
Jarrod Johnson 2021-04-09 15:36:35 -04:00
parent ac4d1fa8e1
commit b6fb91b228

View File

@ -187,8 +187,6 @@ def follow_leader(remote, leader):
log.log({'info': 'Current leader ({0}) has disappeared, restarting '
'collective membership'.format(leader), 'subsystem': 'collective'})
# The leader has folded, time to startup again...
if follower is not None:
follower.kill()
follower = None
cfm.stop_following()
currentleader = None