diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index d9c4a5f..f8d3856 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -311,8 +311,10 @@ where backid=${backid}$ if ne.assignee is None: await self.auto_assign(sor, inst, ne, node) elif ntype == 'task': + debug(f'{ne.node_id}是pending状态的自动任务节点') flg = await self.is_ok_to_step_next(sor, node, edges, inst) if flg: + debug(f'{ne.node_id}可以进入下一步') await self.start_running(sor, inst, ne, node) else: debug(f'{ne.id=}, {node=}, {edges=}不能走下一步') @@ -579,6 +581,7 @@ where instance_id=${instance_id}$ await sor.U('node_execution', ne) async def start_running(self, sor, ne, edges, inst): + debug(f'{ne.node_id}节点运行') await sor.R('node_execution', { 'id': ne['id'], 'status': 'running',