From 78e5301ff89e0f433f4dc351503a6de39404f1c9 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Wed, 29 Apr 2026 11:29:21 -0400
Subject: [PATCH] Fix attempt to await non-async get_nowait.

---
 confluent_server/confluent/plugins/hardwaremanagement/ipmi.py  | 3 ++-
 .../confluent/plugins/hardwaremanagement/redfish.py            | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py
index e8c56134..9776a500 100644
--- a/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py
+++ b/confluent_server/confluent/plugins/hardwaremanagement/ipmi.py
@@ -433,9 +433,10 @@ async def perform_requests(operator, nodes, element, cfg, inputdata, realop):
     try:
         # drain queue if a thread put something on the queue and died
         while True:
-            datum = await resultdata.get_nowait()
+            datum = resultdata.get_nowait()
             if datum != 'Done':
                 yield datum
+            await asyncio.sleep(0)
     except asyncio.QueueEmpty:
         pass
 
diff --git a/confluent_server/confluent/plugins/hardwaremanagement/redfish.py b/confluent_server/confluent/plugins/hardwaremanagement/redfish.py
index 179fcb86..01207d87 100644
--- a/confluent_server/confluent/plugins/hardwaremanagement/redfish.py
+++ b/confluent_server/confluent/plugins/hardwaremanagement/redfish.py
@@ -294,9 +294,10 @@ async def perform_requests(operator, nodes, element, cfg, inputdata, realop):
     try:
         # drain queue if a thread put something on the queue and died
         while True:
-            datum = await resultdata.get_nowait()
+            datum = resultdata.get_nowait()
             if datum != 'Done':
                 yield datum
+            await asyncio.sleep(0)
     except asyncio.QueueEmpty:
         pass