diff --git a/dagflow/dagflow.py b/dagflow/dagflow.py
index 0e71d27..babe2ec 100644
--- a/dagflow/dagflow.py
+++ b/dagflow/dagflow.py
@@ -586,7 +586,7 @@ async def get_org_flow_definition(request):
 	env = request._run_ns
 	orgid = await env.get_userorgid()
 	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 ${orgids}$"""
 		recs = await sor.sqlExe(sql, {'orgids': ['0', orgid]})
 		return recs
 	return []