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-15 21:10:04 +08:00
parent 568466961b
commit 4687856af5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dagflow/dagflow.py
View File

@ -513,10 +513,10 @@ async def list_org_instances(request, flow_def_id=None):
sql = """select b.name, a.* sql = """select b.name, a.*
from flow_instance a, flow_definition b from flow_instance a, flow_definition b
where a.flow_def_id = b.id where a.flow_def_id = b.id
and status='running' and a.status='running'
and org_id=${orgid}$""" and a.org_id=${orgid}$"""
if flow_def_id: if flow_def_id:
sql += ' and flow_def_id = ${flow_def_id}$' sql += ' and a.flow_def_id = ${flow_def_id}$'
recs = await sor.sqlExe(sql, { recs = await sor.sqlExe(sql, {
'orgid': orgid, 'orgid': orgid,
'flow_def_id': flow_def_id 'flow_def_id': flow_def_id