From 4952e87309779b9161f7bdf2004733c7d1e2421a Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 15 Sep 2023 10:52:13 -0400 Subject: [PATCH] Undo collective manager changes Abort attempt to avoid duplicate startups, it was incorrect. --- confluent_server/confluent/collective/manager.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 80c241b8..8d98caa0 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -43,7 +43,7 @@ currentleader = None follower = None retrythread = None failovercheck = None -initting = False +initting = True reassimilate = None class ContextBool(object): @@ -818,9 +818,6 @@ def start_collective(): global follower global retrythread global initting - if initting: - # do not nest startup if startup backs up loops of starting collective - return initting = True retrythread = None try: