diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index dbc12e43..ce397d1a 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -243,7 +243,7 @@ class ConsoleHandler(object): def check_collective(self, attrvalue): myc = attrvalue.get(self.node, {}).get('collective.manager', {}).get( 'value', None) - if configmodule.list_collective() and not myc: + if list(configmodule.list_collective()) and not myc: self._is_local = False self._detach() self._disconnect() diff --git a/confluent_server/confluent/discovery/core.py b/confluent_server/confluent/discovery/core.py index 3cca8095..d18c565d 100644 --- a/confluent_server/confluent/discovery/core.py +++ b/confluent_server/confluent/discovery/core.py @@ -1078,7 +1078,7 @@ def discover_node(cfg, handler, info, nodename, manual): traceback.print_exc() return False newnodeattribs = {} - if cfm.list_collective(): + if list(cfm.list_collective()): # We are in a collective, check collective.manager cmc = cfg.get_node_attributes(nodename, 'collective.manager') cm = cmc.get(nodename, {}).get('collective.manager', {}).get('value', None)