2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-25 23:02:20 +00:00

Check quorum on attribute read

It's too bizarre for attribute read from api to work
without quorum, could be misleading.
This commit is contained in:
Jarrod Johnson 2018-07-12 16:05:04 -04:00
parent 61dd71778f
commit b0c384c9ca
2 changed files with 5 additions and 0 deletions

View File

@ -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

View File

@ -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':