From 78a1741e0e91b3297d8754eb6c231a048ed62dc0 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 1 Oct 2018 16:02:16 -0400 Subject: [PATCH] Fix usage of check_quorum() It is not a boolean, it is exception driven. --- confluent_server/confluent/collective/manager.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 70275d66..33b87323 100644 --- 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: