From 1a0b00e61314ce754685461d0a60de4d4f0a94ac Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 17:49:27 +0800
Subject: [PATCH] bugfix

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

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index b691801..ebbc1f5 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -539,7 +539,7 @@ where instance_id=${instance_id}$
 
 	async def task_error_callback(self, ne_id, errmsg):
 		debug(f'task_error_callback():{ne_id=}, {errmsg=}')
-		env = Server()
+		env = ServerEnv()
 		async with get_sor_context(env, 'dagflow') as sor:
 			recs = await sor.R('node_execution', {'id': ne_id})
 			if not recs: