xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-08 18:01:33 +00:00
Code Issues Projects Releases Wiki Activity

Hook up descriptions to asyncio

Browse Source
This commit is contained in:
Jarrod Johnson
2024-08-22 08:40:34 -04:00
parent 19439463b1
commit 10faac8835
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
confluent_server/confluent/core.py
View File

@@ -95,6 +95,8 @@ async def iterate_responses(responses):
async for rsp in responses:
yield rsp
return
if inspect.isawaitable(responses):
responses = await responses
for rsp in responses:
yield rsp

9
confluent_server/confluent/plugins/hardwaremanagement/ipmi.py
View File

@@ -584,7 +584,7 @@ class IpmiHandler:
elif self.element == ['support', 'servicedata']:
self.handle_servicedata_fetch()
elif self.element == ['description']:
self.handle_description()
await self.handle_description()
else:
raise Exception('Not Implemented')
@@ -1600,9 +1600,10 @@ class IpmiHandler:
self.ipmicmd.delete_license(lic['name'])
else:
self.output.put(msg.License(self.node, feature=lic['name'], state=lic.get('state', 'Active')))
def handle_description(self):
dsc = self.ipmicmd.get_description()
self.output.put(msg.KeyValueData(dsc, self.node))
async def handle_description(self):
dsc = await self.ipmicmd.get_description()
await self.output.put(msg.KeyValueData(dsc, self.node))
def handle_graphical_console(self):
args = self.ipmicmd.get_graphical_console()