bugfix

2026-03-17 18:23:29 +08:00 · 2026-03-17 18:23:29 +08:00 · df88fca973
commit df88fca973
parent 26fbf0e008
1 changed files with 2 additions and 2 deletions
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@ -363,10 +363,10 @@ where backid=${backid}$
 		try:
 			data = await env.run_skillagent(params)
 			debug(f'任务完成，返回数据={data}')
-			self.task_success_callback(ne_id, data)
+			await self.task_success_callback(ne_id, data)
 		except Exception as e:
 			message = f'任务失败错误信息{e}'
-			self.task_error_callback(ne_id, message)
+			await self.task_error_callback(ne_id, message)

 	async def run_auto_task(self, ne):
 		env = ServerEnv()