yumoqing/dagflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-17 11:10:16 +08:00
parent 0a6792e8cf
commit f7aa8eec54
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dagflow/dagflow.py
View File

@ -362,6 +362,8 @@ where backid=${backid}$
for node_id, ctx_ext in nnodes: for node_id, ctx_ext in nnodes:
node = dsl['nodes'][node_id] 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) x = await self.is_ok_to_create_new_node_exe(sor, node, edge, inst)
if x: if x:
env = ServerEnv() env = ServerEnv()
@ -375,8 +377,8 @@ where backid=${backid}$
'input_ctx': node.get('input_ctx'), 'input_ctx': node.get('input_ctx'),
'output_ctx': node.get('output_ctx'), 'output_ctx': node.get('output_ctx'),
'status': 'pending', 'status': 'pending',
'ctx': json.dumps(inst.ctx.copy(), ensure_ascii=False), 'ctx': inst.ctx,
'ctx_ext': json.dumps(ctx_ext.copy(), ensure_ascii=False), 'ctx_ext': ctx_ext,
'created_at': timestampstr() 'created_at': timestampstr()
} }
if node['type'] == 'human': if node['type'] == 'human':