From 26fbf0e00800ac900fda2446dad1cb6c88f9218b Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 17 Mar 2026 18:21:45 +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 32d94af..2d94956 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.self.task_success_callback(ne_id, data) + self.task_success_callback(ne_id, data) except Exception as 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): env = ServerEnv()