From 40ea5e12a9602072e61cdd90bb37ac4a38362287 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 12 Feb 2026 15:36:27 +0800 Subject: [PATCH] bugfix --- skillagent/skillengine.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/skillagent/skillengine.py b/skillagent/skillengine.py index 7299bb7..c6940ba 100644 --- a/skillagent/skillengine.py +++ b/skillagent/skillengine.py @@ -86,7 +86,7 @@ class IndustrialSkillEngine: # 状态机:记录当前任务执行到的步骤 self.state = {"current_skill": None, "history": [], "pending_params": []} - async def write_output(self, data=None): + async def write_output(self, data): debug('-----------write_output() called: {data=}') await self.task_queue.put(data) @@ -191,7 +191,6 @@ class IndustrialSkillEngine: f = partial(self.run, params_kw) asyncio.create_task(self.run(params_kw)) while True: - data = await self.task_queue.get() if not data: debug('End Data')