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