From b6fb91b228d7b0747b6a702ffa2cd9226417a273 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 9 Apr 2021 15:36:35 -0400 Subject: [PATCH] Have follower thread avoid killing self --- confluent_server/confluent/collective/manager.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 06109be7..7f779601 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -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