elif field == "drain_flag":
entry = os.path.exists(constants.JOB_QUEUE_DRAIN_FILE)
elif field == "watcher_pause":
- return utils.ReadWatcherPauseFile(constants.WATCHER_PAUSEFILE)
+ entry = utils.ReadWatcherPauseFile(constants.WATCHER_PAUSEFILE)
else:
raise errors.ParameterError(field)
values.append(entry)
ToStdout(master)
return 0
+
def _PrintGroupedParams(paramsdict):
"""Print Grouped parameters (be, nic, disk) by group.
for item, val in gr_dict.iteritems():
ToStdout(" %s: %s", item, val)
+
def ShowClusterConfig(opts, args):
"""Shows cluster information.
elif command == "info":
result = client.QueryConfigValues(["watcher_pause"])
- _ShowWatcherPause(result)
+ _ShowWatcherPause(result[0])
else:
raise errors.OpPrereqError("Command '%s' is not valid." % command,