bugfix

2026-03-16 17:10:17 +08:00 · 2026-03-16 17:10:17 +08:00 · d943835cb8
commit d943835cb8
parent 3919bf115e
1 changed files with 1 additions and 1 deletions
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@ -345,7 +345,7 @@ where backid=${backid}$
 	
 	async def node_transfer(self, sor, dsl, inst, ne, node, flow_def):
 		nnode = []
-		ctx = inst.ctx.copy()
+		ctx = json.loads(inst.ctx)
 		for edge in dsl.get('edges', []):
 			if edge['from'] != ne.node_id:
 				continue