From df88fca97341341047eea0e735a9ae582adf9f85 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 18:23:29 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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()