xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-06-25 00:40:52 +00:00
Code Issues Projects Releases Wiki Activity

Asyncify proxmox retrieve function

Browse Source
This commit is contained in:
Jarrod Johnson
2026-01-22 14:53:52 -05:00
parent b548002a8d
commit b06ffb293a
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
confluent_server/confluent/plugins/hardwaremanagement/proxmox.py
+4 -4
View File
@@ -396,16 +396,16 @@ def prep_proxmox_clients(nodes, configmanager):
clientsbynode[node] = clientsbypmx[currpmx]
return clientsbynode
def retrieve(nodes, element, configmanager, inputdata):
async def retrieve(nodes, element, configmanager, inputdata):
clientsbynode = prep_proxmox_clients(nodes, configmanager)
for node in nodes:
currclient = clientsbynode[node]
if element == ['power', 'state']:
yield msg.PowerState(node, currclient.get_vm_power(node))
yield msg.PowerState(node, await currclient.get_vm_power(node))
elif element == ['boot', 'nextdevice']:
yield msg.BootDevice(node, currclient.get_vm_bootdev(node))
yield msg.BootDevice(node, await currclient.get_vm_bootdev(node))
elif element[:2] == ['inventory', 'hardware'] and len(element) == 4:
for rsp in currclient.get_vm_inventory(node):
for rsp in await currclient.get_vm_inventory(node):
yield rsp
elif element == ['console', 'ikvm_methods']:
dsc = {'ikvm_methods': ['vnc']}