From b06ffb293a716ec7cb3b9c562b55a6b98a0cc546 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 22 Jan 2026 14:53:52 -0500 Subject: [PATCH] Asyncify proxmox retrieve function --- .../confluent/plugins/hardwaremanagement/proxmox.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py b/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py index 215d4a71..9b5b774b 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/proxmox.py @@ -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']}