Fix usage of check_quorum()

It is not a boolean, it is exception driven.
2024-11-22 09:32:21 +00:00 · 2018-10-01 16:02:16 -04:00 · 2018-10-01 16:02:16 -04:00 · 78a1741e0e
commit 78a1741e0e
parent 4329c1d388
1 changed files with 2 additions and 1 deletions
--- a/confluent_server/confluent/collective/manager.py
+++ b/confluent_server/confluent/collective/manager.py
@ -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: