From d6289c8671cfda41779a70f3af2582acbd5c135c Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 17 Mar 2026 17:02:39 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index 90a4ce6..cdcd00c 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -310,11 +310,11 @@ where backid=${backid}$ if ne.assignee is None: await self.auto_assign(sor, inst, ne, node) 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: await self.start_running(sor, inst, ne, node) 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: await self.start_subflow(sor, inst, ne, node) elif status in ['done', 'cancelled']: