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 15:50:35 +08:00
parent c12553990b
commit 380097f167
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dagflow/dagflow.py
View File

@ -274,6 +274,7 @@ where backid=${backid}$
))[0] ))[0]
dsl = yaml.safe_load(flow_def['dsl']) dsl = yaml.safe_load(flow_def['dsl'])
edges = dsl.get('edges',[])
ctx = json.loads(inst['ctx']) ctx = json.loads(inst['ctx'])
sql = "select * from node_execution where instance_id=${instance_id}$ and status != 'completed'" sql = "select * from node_execution where instance_id=${instance_id}$ and status != 'completed'"
active_nes = await sor.sqlExe(sql, { active_nes = await sor.sqlExe(sql, {