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')