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:26:42 +08:00
parent 8ab0df9360
commit 015765960c
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

@ -315,7 +315,7 @@ where backid=${backid}$
flg = await self.is_ok_to_step_next(sor, node, edges, inst) flg = await self.is_ok_to_step_next(sor, node, edges, inst)
if flg: if flg:
debug(f'{ne.node_id}可以进入下一步') debug(f'{ne.node_id}可以进入下一步')
await self.start_running(sor, inst, ne, node) await self.start_running(sor, inst, ne)
else: else:
debug(f'{ne.id=}, {node=}, {edges=}不能走下一步') debug(f'{ne.id=}, {node=}, {edges=}不能走下一步')
elif ntype == 'subflow': elif ntype == 'subflow':
@ -580,7 +580,7 @@ where instance_id=${instance_id}$
ne.output = None ne.output = None
await sor.U('node_execution', ne) await sor.U('node_execution', ne)
async def start_running(self, sor, ne, edges, inst): async def start_running(self, sor, inst, ne):
debug(f'{ne.node_id}节点运行') debug(f'{ne.node_id}节点运行')
await sor.R('node_execution', { await sor.R('node_execution', {
'id': ne['id'], 'id': ne['id'],