fix: sor.R() 3rd arg → sqlExe with ORDER BY

2026-08-02 15:51:59 +08:00 · 2026-08-02 15:51:59 +08:00 · f172889fbb
commit f172889fbb
parent 59e56b5e9c
1 changed files with 1 additions and 1 deletions
--- 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 = []