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