xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-08-03 16:07:00 +00:00
Code Issues Projects Releases Wiki Activity

Complete the async port of the nodegroup attribute paths

Browse Source 
simple_nodegroups_command awaited the async generators returned by read
and update, which raises

  TypeError: 'async_generator' object can't be awaited

and printgroupattributes was left synchronous, iterating one of those
generators with plain for.  Neither is reachable yet, since nodeattrib
only ever passes a noderange and nodegroupattrib still uses the
traditional client, but they are the paths nodegroupattrib will use once
it is ported.
This commit is contained in:
Markus Hilger
2026-07-27 01:52:09 +02:00
parent 550751d0ff
commit 64cfad09af
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
confluent_client/confluent/asynclient.py
+4 -4
View File
@@ -347,12 +347,12 @@ class Command(object):
else:
ikey = key
if input is None:
for res in await self.read('/nodegroups/{0}/{1}'.format(
async for res in self.read('/nodegroups/{0}/{1}'.format(
noderange, resource)):
rc = self.handle_results(ikey, rc, res)
else:
kwargs[ikey] = input
for res in await self.update('/nodegroups/{0}/{1}'.format(
async for res in self.update('/nodegroups/{0}/{1}'.format(
noderange, resource), kwargs):
rc = self.handle_results(ikey, rc, res)
return rc
@@ -667,10 +667,10 @@ def show_attr(attr, requestargs, seenattributes, options, node):
return processattr
def printgroupattributes(session, requestargs, showtype, nodetype, noderange, options):
async def printgroupattributes(session, requestargs, showtype, nodetype, noderange, options):
exitcode = 0
seenattributes = set([])
for res in session.read('/{0}/{1}/attributes/{2}'.format(nodetype, noderange, showtype)):
async for res in session.read('/{0}/{1}/attributes/{2}'.format(nodetype, noderange, showtype)):
if 'error' in res:
sys.stderr.write(res['error'] + '\n')
exitcode = 1