diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 900958ca..1e7eb4ff 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -828,6 +828,10 @@ class ConfigManager(object): def get_collective_member(self, name): return get_collective_member(name) + @classmethod + def check_quorum(cls): + return check_quorum() + def filter_node_attributes(self, expression, nodes=None): """Filtered nodelist according to expression diff --git a/confluent_server/confluent/plugins/configuration/attributes.py b/confluent_server/confluent/plugins/configuration/attributes.py index 36baf330..2b135790 100644 --- a/confluent_server/confluent/plugins/configuration/attributes.py +++ b/confluent_server/confluent/plugins/configuration/attributes.py @@ -20,6 +20,7 @@ import confluent.util as util def retrieve(nodes, element, configmanager, inputdata): + configmanager.check_quorum() if nodes is not None: return retrieve_nodes(nodes, element, configmanager, inputdata) elif element[0] == 'nodegroups':