2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-29 04:50:21 +00:00

Undo collective manager changes

Abort attempt to avoid duplicate startups, it was incorrect.
This commit is contained in:
Jarrod Johnson 2023-09-15 10:52:13 -04:00
parent 533244458d
commit 4952e87309

View File

@ -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: