From 9d6f66965de410d48f4c623e7d015a4582ea2f2f Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sun, 15 Mar 2026 20:25:02 +0800 Subject: [PATCH] bugfix --- dagflow/dagflow.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py index a4b80fc..0bdb47c 100644 --- a/dagflow/dagflow.py +++ b/dagflow/dagflow.py @@ -584,7 +584,7 @@ async def add_new_workflow(request, params_kw={}): async def get_org_flow_definition(request): env = request._run_ns - orgids = await env.get_userorgid() + orgid = await env.get_userorgid() async with get_sor_context(env, 'dagflow') as sor: sql = """select * from flow_definition where org_id in ${orids}$""" recs = sor.sqlExe(sql, {'orgids': ['0', orgid]})