diff --git a/init.py b/init.py
index 269aaf2..ad27d6b 100644
--- a/init.py
+++ b/init.py
@@ -44,11 +44,7 @@ async def engines_handler(request, params_kw, *args, **kwargs):
     try:
         userorgid = await env.get_userorgid()
         async with get_sor_context(env, 'rag') as sor:
-            sql = """
-                SELECT * FROM engine_configs 
-                WHERE status='active' AND (org_id IS NULL OR org_id=%s)
-                ORDER BY engine_type, priority DESC
-            """
+            sql = "SELECT * FROM engine_configs WHERE status='active' AND (org_id IS NULL OR org_id=${org_id}$) ORDER BY engine_type, priority DESC"
             recs = await sor.sqlExe(sql, {"org_id": userorgid})
             return json.dumps({
                 "status": "SUCCEEDED",