From f7aa8eec54867fbd2923da564abe84ccdd173a37 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 17 Mar 2026 11:10:16 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index ba7d5d7..229be18 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -362,6 +362,8 @@ where backid=${backid}$ for node_id, ctx_ext in nnodes: node = dsl['nodes'][node_id] + if isinstance(ctx_ext, dict) or isinstance(ctx_ext, list): + ctx_ext = json.dumps(ctx_ext, ensure_ascii=False) x = await self.is_ok_to_create_new_node_exe(sor, node, edge, inst) if x: env = ServerEnv() @@ -375,8 +377,8 @@ where backid=${backid}$ 'input_ctx': node.get('input_ctx'), 'output_ctx': node.get('output_ctx'), 'status': 'pending', - 'ctx': json.dumps(inst.ctx.copy(), ensure_ascii=False), - 'ctx_ext': json.dumps(ctx_ext.copy(), ensure_ascii=False), + 'ctx': inst.ctx, + 'ctx_ext': ctx_ext, 'created_at': timestampstr() } if node['type'] == 'human':