2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-14 19:59:00 +00:00

Correct to async for in refish retriev

This commit is contained in:
Jarrod Johnson
2026-01-23 20:46:57 -05:00
parent 52bb240aff
commit 50ec0bbca6

View File

@@ -1633,8 +1633,9 @@ async def retrieve(nodes, element, configmanager, inputdata):
return await firmwaremanager.list_updates(nodes, configmanager.tenant,
element, 'ffdc')
else:
return await perform_requests('read', nodes, element, configmanager,
inputdata, 'read')
async for x in perform_requests('read', nodes, element, configmanager,
inputdata, 'read'):
yield x
async def delete(nodes, element, configmanager, inputdata):
if '/'.join(element).startswith('inventory/firmware/updates/active'):