mirror of
https://github.com/xcat2/confluent.git
synced 2026-06-18 01:20:47 +00:00
Normalize various iterables for single node responses
This commit is contained in:
@@ -719,7 +719,7 @@ def show_user(name, configmanager):
|
||||
|
||||
|
||||
async def stripnode(iterablersp, node):
|
||||
async for i in iterablersp:
|
||||
async for i in iterate_responses(iterablersp):
|
||||
if i is None:
|
||||
raise exc.NotImplementedException("Not Implemented")
|
||||
if isinstance(i, console.Console):
|
||||
|
||||
@@ -349,6 +349,8 @@ def prep_vcsa_clients(nodes, configmanager):
|
||||
clientsbynode = {}
|
||||
for node in nodes:
|
||||
cfg = cfginfo[node]
|
||||
if 'hardwaremanagement.manager' not in cfg or 'value' not in cfg['hardwaremanagement.manager']:
|
||||
raise Exception("Missing hardwaremanagement.manager for node {}".format(node))
|
||||
currvcsa = cfg['hardwaremanagement.manager']['value']
|
||||
if currvcsa not in clientsbyvcsa:
|
||||
user = cfg.get('secret.hardwaremanagementuser', {}).get('value', None)
|
||||
|
||||
Reference in New Issue
Block a user