From 1fd986cc9a1f9f4382fff62eab4255700f618e5d Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 2 Mar 2026 16:43:12 -0500 Subject: [PATCH] async fixes for ipmi --- .../confluent/plugins/hardwaremanagement/ipmi.py | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py index 9de80934..e6bce129 100644 --- a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py +++ b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py @@ -878,14 +878,14 @@ class IpmiHandler: event['component_type_id']) async def make_inventory_map(self): - invnames = await self.ipmicmd.get_inventory_descriptions() - for name in invnames: + invnames = self.ipmicmd.get_inventory_descriptions() + async for name in invnames: self.invmap[simplify_name(name)] = name async def make_sensor_map(self, sensors=None): if sensors is None: - sensors = await self.ipmicmd.get_sensor_descriptions() - for sensor in sensors: + sensors = self.ipmicmd.get_sensor_descriptions() + async for sensor in sensors: resourcename = sensor['name'] self.ipmicmd.sensormap[simplify_name(resourcename)] = resourcename @@ -957,8 +957,10 @@ class IpmiHandler: await self.output.put(msg.ConfluentTargetTimeout(self.node)) async def list_inventory(self): + components = [] try: - components = self.ipmicmd.get_inventory_descriptions() + async for component in self.ipmicmd.get_inventory_descriptions(): + components.append(component) except pygexc.IpmiException: await self.output.put(msg.ConfluentTargetTimeout(self.node)) return