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