yumoqing/skillagent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-02-12 15:36:27 +08:00
parent 7f3400214a
commit 40ea5e12a9
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
skillagent/skillengine.py
View File

@ -86,7 +86,7 @@ class IndustrialSkillEngine:
# 状态机：记录当前任务执行到的步骤 # 状态机：记录当前任务执行到的步骤
self.state = {"current_skill": None, "history": [], "pending_params": []} 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=}') debug('-----------write_output() called: {data=}')
await self.task_queue.put(data) await self.task_queue.put(data)
@ -191,7 +191,6 @@ class IndustrialSkillEngine:
f = partial(self.run, params_kw) f = partial(self.run, params_kw)
asyncio.create_task(self.run(params_kw)) asyncio.create_task(self.run(params_kw))
while True: while True:
data = await self.task_queue.get() data = await self.task_queue.get()
if not data: if not data:
debug('End Data') debug('End Data')