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: