2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-27 03:49:57 +00:00

Fix usage of check_quorum()

It is not a boolean, it is exception driven.
This commit is contained in:
Jarrod Johnson 2018-10-01 16:02:16 -04:00
parent c13ebe36ae
commit 29fcd59f8b

View File

@ -536,7 +536,8 @@ def start_collective():
follower.kill()
follower = None
try:
if cfm.cfgstreams and cfm.check_quorum():
if cfm.cfgstreams:
cfm.check_quorum()
# Do not start if we have quorum and are leader
return
except exc.DegradedCollective: