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']: