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-13 14:48:07 +08:00
parent 3228ccd246
commit dad106b4ff
1 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
dagflow/dagflow.py
View File

@ -435,25 +435,26 @@ where instance_id=${instance_id}$
return False return False
async def start_running(self, sor, node, edges, inst): async def start_running(self, sor, node, edges, inst):
if self.is_ok_to_start(sor, node, edges, inst): if self.s_ok_to_step_next(sor, node, edges, inst):
await sor.R('node_execution', { await sor.R('node_execution', {
'id': node['id'], 'id': node['id'],
'status': 'running' 'status': 'running',
'running_time': }) 'running_time': timestampstr()
try:
out = await self.run_auto_task(node)
sor.U('node_execution', {
'id': node['id'],
'status': 'done',
'stopping_at': timestampstr(),
'output_ctx': json.dumps(out, ensure_ascii=False)
}) })
except Exception as e: try:
sor.U('node_execution', { out = await self.run_auto_task(node)
'id': node['id'], sor.U('node_execution', {
'status': 'failed', 'id': node['id'],
'stopping_at': timestampstr() 'status': 'done',
} 'stopping_at': timestampstr(),
'output_ctx': json.dumps(out, ensure_ascii=False)
})
except Exception as e:
sor.U('node_execution', {
'id': node['id'],
'status': 'failed',
'stopping_at': timestampstr()
}
async def list_human_tasks(self, org_id, user_roles): async def list_human_tasks(self, org_id, user_roles):
env = ServerEnv() env = ServerEnv()