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 14:22:41 +08:00
parent ddceb69b20
commit f33471ca5e
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
skillagent/skillengine.py
View File

@ -194,7 +194,7 @@ class IndustrialSkillEngine:
if not data: if not data:
break; break;
debug(f'{data=}, {type(data)=}') debug(f'{data=}, {type(data)=}')
yield data yield json.dump(data, ensure_ascii=False) + '\n'
await asyncio.sleep(0.1) await asyncio.sleep(0.1)
@ -257,10 +257,20 @@ class IndustrialSkillEngine:
if "EXEC:" in decision: if "EXEC:" in decision:
cmd = decision.split("EXEC:")[1].strip() cmd = decision.split("EXEC:")[1].strip()
output = await self._execute_with_retry(cmd, skill_name) output = await self._execute_with_retry(cmd, skill_name)
if isinstance(output, str):
output = {
"status": "SUCCEEDED",
"content": output
}
await self.write_output(output) await self.write_output(output)
return return
if "ANSWER:" in decision: if "ANSWER:" in decision:
output = decision.replace("ANSWER:", "").strip() output = decision.replace("ANSWER:", "").strip()
if isinstance(output, str):
output = {
"status": "SUCCEEDED",
"content": output
}
await self.write_output(output) await self.write_output(output)
return output return output
debug(f' undefined decision:{decision}') debug(f' undefined decision:{decision}')