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:02:39 +08:00
parent 7ac6d1d936
commit d6289c8671
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

@ -310,11 +310,11 @@ where backid=${backid}$
if ne.assignee is None: if ne.assignee is None:
await self.auto_assign(sor, inst, ne, node) await self.auto_assign(sor, inst, ne, node)
elif ntype == 'task': elif ntype == 'task':
flg= 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:
await self.start_running(sor, inst, ne, node) await self.start_running(sor, inst, ne, node)
elif ntype == 'subflow': elif ntype == 'subflow':
flg= 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:
await self.start_subflow(sor, inst, ne, node) await self.start_subflow(sor, inst, ne, node)
elif status in ['done', 'cancelled']: elif status in ['done', 'cancelled']: