From 52bb240aff760b9697d57dd0f2f91ba3e936aa70 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 23 Jan 2026 20:45:44 -0500 Subject: [PATCH] Wire up async mechanism in redfish --- .../plugins/hardwaremanagement/redfish.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/confluent_server/confluent/plugins/hardwaremanagement/redfish.py b/confluent_server/confluent/plugins/hardwaremanagement/redfish.py index 9dc51e41..ace114cc 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/redfish.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/redfish.py @@ -1613,30 +1613,30 @@ def _str_health(health): -def create(nodes, element, configmanager, inputdata, realop='create'): +async def create(nodes, element, configmanager, inputdata, realop='create'): return perform_requests( 'update', nodes, element, configmanager, inputdata, realop) -def update(nodes, element, configmanager, inputdata): +async def update(nodes, element, configmanager, inputdata): return create(nodes, element, configmanager, inputdata, 'update') -def retrieve(nodes, element, configmanager, inputdata): +async def retrieve(nodes, element, configmanager, inputdata): if '/'.join(element).startswith('inventory/firmware/updates/active'): - return firmwaremanager.list_updates(nodes, configmanager.tenant, + return await firmwaremanager.list_updates(nodes, configmanager.tenant, element) elif '/'.join(element).startswith('media/uploads'): - return firmwaremanager.list_updates(nodes, configmanager.tenant, + return awaitfirmwaremanager.list_updates(nodes, configmanager.tenant, element, 'mediaupload') elif '/'.join(element).startswith('support/servicedata'): - return firmwaremanager.list_updates(nodes, configmanager.tenant, + return await firmwaremanager.list_updates(nodes, configmanager.tenant, element, 'ffdc') else: - return perform_requests('read', nodes, element, configmanager, + return await perform_requests('read', nodes, element, configmanager, inputdata, 'read') -def delete(nodes, element, configmanager, inputdata): +async def delete(nodes, element, configmanager, inputdata): if '/'.join(element).startswith('inventory/firmware/updates/active'): return firmwaremanager.remove_updates(nodes, configmanager.tenant, element)