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-16 16:36:14 +08:00
parent bb0a1d89e4
commit 1c11a995d7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dagflow/dagflow.py
View File

@ -260,7 +260,7 @@ where backid=${backid}$
elif ntype == 'subflow': elif ntype == 'subflow':
await self.try_start_subflow(sor, inst, ne, node) await self.try_start_subflow(sor, inst, ne, node)
elif ntype == 'start': elif ntype == 'start':
await self.node_transfer(sor, inst, ne, node, flow_def) await self.node_transfer(sor, dsl, inst, ne, node, flow_def)
await sor.U('node_execution', { await sor.U('node_execution', {
'id': ne.id, 'id': ne.id,
'status': 'completed' 'status': 'completed'
@ -278,7 +278,7 @@ where backid=${backid}$
}) })
break; break;
elif status in ['done', 'cancelled', 'failed']: elif status in ['done', 'cancelled', 'failed']:
await self.node_transfer(sor, inst, ne, node, flow_def) await self.node_transfer(sor, dsl, inst, ne, node, flow_def)
await sor.U('node_execution', { await sor.U('node_execution', {
'id': ne.id, 'id': ne.id,
'status': 'completed' 'status': 'completed'