yumoqing/dagflow
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-17 18:21:45 +08:00
parent da86a5417e
commit 26fbf0e008
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dagflow/dagflow.py
View File

@ -363,10 +363,10 @@ where backid=${backid}$
try: try:
data = await env.run_skillagent(params) data = await env.run_skillagent(params)
debug(f'任务完成，返回数据={data}') debug(f'任务完成，返回数据={data}')
self.self.task_success_callback(ne_id, data) self.task_success_callback(ne_id, data)
except Exception as e: except Exception as e:
message = f'任务失败错误信息{e}' message = f'任务失败错误信息{e}'
self.self.task_error_callback(ne_id, message) self.task_error_callback(ne_id, message)
async def run_auto_task(self, ne): async def run_auto_task(self, ne):
env = ServerEnv() env = ServerEnv()