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 20:25:02 +08:00
parent 4470f9a538
commit 9d6f66965d
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

@ -584,7 +584,7 @@ async def add_new_workflow(request, params_kw={}):
async def get_org_flow_definition(request): async def get_org_flow_definition(request):
env = request._run_ns env = request._run_ns
orgids = await env.get_userorgid() orgid = await env.get_userorgid()
async with get_sor_context(env, 'dagflow') as sor: async with get_sor_context(env, 'dagflow') as sor:
sql = """select * from flow_definition where org_id in ${orids}$""" sql = """select * from flow_definition where org_id in ${orids}$"""
recs = sor.sqlExe(sql, {'orgids': ['0', orgid]}) recs = sor.sqlExe(sql, {'orgids': ['0', orgid]})