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-17 13:22:30 +08:00
parent c1bca0a8e0
commit 9613b02ffe
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dagflow/dagflow.py
View File

@ -335,7 +335,7 @@ where backid=${backid}$
async def check_instance_completed(self, sor, inst): async def check_instance_completed(self, sor, inst):
sql = "select * from node_execution where instance_id=${instance_id} and type='end'" sql = "select * from node_execution where instance_id=${instance_id} and type='end'"
recs = await sor.sqlExe(sql, {'instance_id', inst.id}) recs = await sor.sqlExe(sql, {'instance_id': inst.id})
if recs: if recs:
if recs[0].status == 'completed': if recs[0].status == 'completed':
await sor.U('flow_instance', { await sor.U('flow_instance', {