From 9299d74db554e5b7d51d15ac0c0d0cee0c8fb50a Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 17:31:35 +0800
Subject: [PATCH] bugfix

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

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 79519cb..e102137 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -535,6 +535,7 @@ where instance_id=${instance_id}$
 		return False
 
 	async def task_error_callback(self, ne_id, errmsg):
+		debug(f'task_error_callback():{ne_id=}, {errmsg=}')
 		env = Server()
 		async with get_sor_context(env, 'dagflow') as sor:
 			recs = await sor.R('node_execution', {'id': ne_id})
@@ -547,6 +548,7 @@ where instance_id=${instance_id}$
 			await sor.U('node_execution', ne)
 
 	async def task_success_callback(self, ne_id, result):
+		debug(f'task_error_callback():{ne_id=}, {result=}')
 		env = ServerEnv()
 		async with get_sor_context(env, 'dagflow') as sor:
 			recs = await sor.R('node_execution', {'id': ne_id})