fix: resolve create_task type error in tool_loop_agent_runner

This commit is contained in:
LIghtJUNction
2026-03-30 17:36:26 +08:00
parent e8557909d6
commit e1c4b52fba

View File

@@ -1053,7 +1053,9 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
"Tool execution interrupted before reading the next tool result."
)
next_result_task = asyncio.create_task(anext(executor))
async def _get_next():
return await anext(executor)
next_result_task = asyncio.create_task(_get_next())
abort_task = asyncio.create_task(self._abort_signal.wait())
self.tasks.add(next_result_task)
self.tasks.add(abort_task)