diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 2d94956..4e2395e 100644
--- 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()