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 13:26:31 +08:00
parent 9613b02ffe
commit c59e2dbaae
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dagflow/dagflow.py
View File

@ -312,6 +312,7 @@ where backid=${backid}$
}) })
break; break;
elif status in ['done', 'cancelled', 'failed']: elif status in ['done', 'cancelled', 'failed']:
debug(f'节点完成，检查后续节点')
await self.node_transfer(sor, dsl, 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,
@ -346,6 +347,7 @@ where backid=${backid}$
async def node_transfer(self, sor, dsl, inst, ne, node, flow_def): async def node_transfer(self, sor, dsl, inst, ne, node, flow_def):
nnodes = [] nnodes = []
ctx = json.loads(inst.ctx) ctx = json.loads(inst.ctx)
debug(f'{dsl=}, {inst=}, {ne=}, {node=}')
for edge in dsl.get('edges', []): for edge in dsl.get('edges', []):
if edge['from'] != ne.node_id: if edge['from'] != ne.node_id:
continue continue