diff --git a/pipeline_service/storage.py b/pipeline_service/storage.py
index cdec6f4..d507da4 100644
--- a/pipeline_service/storage.py
+++ b/pipeline_service/storage.py
@@ -21,7 +21,7 @@ async def get_pipeline_steps(pipeline_id: str) -> list:
     """
     db, dbname = _get_db()
     async with db.sqlorContext(dbname) as sor:
-        recs = await sor.R('pipeline_steps', {'pipeline_id': pipeline_id}, sort='step_order')
+        recs = await sor.sqlExe('SELECT * FROM pipeline_steps WHERE pipeline_id=${pid}$ ORDER BY step_order', {'pid': pipeline_id})
         if not recs:
             return []
         result = []