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]})