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 17:17:57 +08:00
parent 6538efb6ac
commit 27c9e95898
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

@ -280,6 +280,7 @@ where backid=${backid}$
active_nes = await sor.sqlExe(sql, { active_nes = await sor.sqlExe(sql, {
'instance_id': inst.id 'instance_id': inst.id
}) })
debug(f'活动节点：{active_nes}')
for ne in active_nes: for ne in active_nes:
node_id = ne.node_id node_id = ne.node_id
node = dsl['nodes'][node_id] node = dsl['nodes'][node_id]
@ -330,6 +331,7 @@ where backid=${backid}$
}) })
elif status == 'failed': elif status == 'failed':
debug(f'节点执行失败，需要运维人员参与') debug(f'节点执行失败，需要运维人员参与')
debug(f'{ne.node_id}处理完成')
def build_node_input_ctx(self, inst, ne): def build_node_input_ctx(self, inst, ne):