bugfix
This commit is contained in:
parent
27c9e95898
commit
8ab0df9360
@ -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',
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user