From 4a938728b890a695fa7dca19f0ed3d00abc25e86 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 12 Feb 2026 15:28:36 +0800 Subject: [PATCH] bugfix --- skillagent/skillengine.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/skillagent/skillengine.py b/skillagent/skillengine.py index 5cf6cc3..7299bb7 100644 --- a/skillagent/skillengine.py +++ b/skillagent/skillengine.py @@ -87,6 +87,7 @@ class IndustrialSkillEngine: self.state = {"current_skill": None, "history": [], "pending_params": []} async def write_output(self, data=None): + debug('-----------write_output() called: {data=}') await self.task_queue.put(data) # --- 1. 工业级初始化:依赖检查与索引 --- @@ -186,12 +187,14 @@ class IndustrialSkillEngine: return base_content - async def reference(self, params_kw): + async def inference(self, params_kw): 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') break; debug(f'{data=}, {type(data)=}') yield json.dump(data, ensure_ascii=False) + '\n'