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-03-05 17:34:32 +08:00
parent 814c927b61
commit 024fd55699
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
skillagent/skillengine.py
View File

@ -256,6 +256,7 @@ class IndustrialSkillEngine:
await self.write_output(output) await self.write_output(output)
if "CALL: " in decision: if "CALL: " in decision:
st = decision[6:] st = decision[6:]
debug(f'函数调用：{st=}')
d = DictObject(**json.loads(st)) d = DictObject(**json.loads(st))
env = self.request._run_ns env = self.request._run_ns
f = env.get(d.function) f = env.get(d.function)
@ -263,6 +264,7 @@ class IndustrialSkillEngine:
e = Exception(f'function({d.function} is not in env') e = Exception(f'function({d.function} is not in env')
exception(f'{e}') exception(f'{e}')
raise e raise e
try:
ret = '' ret = ''
if inspect.iscoroutinefunction(f): if inspect.iscoroutinefunction(f):
ret = await f(self.request, params_kw=d.params) ret = await f(self.request, params_kw=d.params)
@ -272,6 +274,12 @@ class IndustrialSkillEngine:
"status": "SUCCEEDED", "status": "SUCCEEDED",
"content": ret "content": ret
}) })
except Exception as e:
exception(f'{e}\n{format_exc()}')
await self.write_output({
"status": "FAILED",
"error": f'{e}'
})
return return
if "REPLY: " in decision: if "REPLY: " in decision:
sessionkey = getID() sessionkey = getID()