From d943835cb8d0737dc004e5dceab00950828b89ff Mon Sep 17 00:00:00 2001 From: yumoqing Date: Mon, 16 Mar 2026 17:10:17 +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 72454eb..6d49b53 100644 --- 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