From ab16535041de518fc19c7e6f475c1c7ea5aa9e54 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Tue, 17 Mar 2026 17:48:10 +0800
Subject: [PATCH] bugfix

---
 dagflow/dagflow.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 97bc9ba..b691801 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -337,7 +337,7 @@ where backid=${backid}$
 				debug(f'{ne.node_id}处理完成')
 				
 
-	def build_node_input_ctx(self, inst, ne):
+	def build_node_input_ctx(self, ne):
 		ctx = json.loads(ne.ctx)
 		if ne.ctx_ext:
 			ctx_ext = json.loads(ns.ctx_ext)
@@ -349,7 +349,7 @@ where backid=${backid}$
 		if subflow_id is None:
 			debug(f'{node=} 没有subflow_id属性')
 			return
-		sub_ctx = self.build_node_input_ctx(inst, ne)
+		sub_ctx = self.build_node_input_ctx(ne)
 		ne.subinst_id = await self.create_instance(
 			ne.org_id, 
 			subflow_id, ctx=sub_ctx)
@@ -363,7 +363,7 @@ where backid=${backid}$
 		if not users:
 			debug(f'{ne.org_id=} 没有用户')
 			return
-		sub_ctx = self.build_node_input_ctx(inst, ne)
+		sub_ctx = self.build_node_input_ctx(ne)
 		try:
 			f = partial(self.task_success_callback, ne.id)
 			ef = partial(self.task_error_callback, ne.id)