2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-05-01 04:47:45 +00:00

Fix accidental change of iterating data in ipmi

This commit is contained in:
Jarrod Johnson
2026-04-29 10:53:18 -04:00
parent 27b951b7cb
commit 5064ac80b9

View File

@@ -416,8 +416,8 @@ async def perform_requests(operator, nodes, element, cfg, inputdata, realop):
numnodes -= 1
else:
yield datum
timeout = 0.1 if numnodes else 0.001
datum = await asyncio.wait_for(resultdata.get(), timeout=timeout)
timeout = 0.1 if numnodes else 0.001
datum = await asyncio.wait_for(resultdata.get(), timeout=timeout)
except asyncio.QueueEmpty:
pass
except asyncio.TimeoutError: