From 4687856af50ccfe669806fe46cf668418af7a99d Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sun, 15 Mar 2026 21:10:04 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index babe2ec..e1a8b92 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -513,10 +513,10 @@ async def list_org_instances(request, flow_def_id=None): sql = """select b.name, a.* from flow_instance a, flow_definition b where a.flow_def_id = b.id - and status='running' - and org_id=${orgid}$""" + and a.status='running' + and a.org_id=${orgid}$""" 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, { 'orgid': orgid, 'flow_def_id': flow_def_id