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-13 14:40:59 +08:00
parent 4d9d571812
commit 6b19f14ee8
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dagflow/dagflow.py
View File

@ -360,13 +360,11 @@ where backid=${backid}$
'subinst_id': subinst_id 'subinst_id': subinst_id
}) })
elif node['type'] == 'end': elif node['type'] == 'end':
ns.update('
await self.create_end_node_execution(sor, inst) await self.create_end_node_execution(sor, inst)
continue
await sor.C('node_execution', ns) await sor.C('node_execution', ns)
if node.join
async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst): async def is_ok_to_create_new_node_exe(self, sor, node, edges, inst):
join = node.get('join) join = node.get('join)
if join is None: if join is None: