fix: insert await asyncio.sleep(0) to yield control in loop (#1186)

2026-07-27 15:37:44 +00:00 · 2025-08-15 13:27:29 +08:00
parent 481e226844
commit e0453e0058
1 changed files with 1 additions and 0 deletions
@@ -304,6 +304,7 @@ class LoopBase:
                await self._run_step(li)
            self.queue.put_nowait(li)  # the loop `li` has been kicked off, waiting for workers to pick it up
            self.loop_idx += 1
+            await asyncio.sleep(0)

    async def execute_loop(self) -> None:
        while True: