Fix: support older aiosqlite without execute_fetch*

backend/storage/sqlite_run_store.py

@@ -183,7 +183,7 @@ class SQLiteRunStore:
         async with aiosqlite.connect(self.db_path) as db:
             await db.execute("PRAGMA foreign_keys=ON;")
             if mode:
-                rows = await db.execute_fetchall(
+                cursor = await db.execute(
                     """
                     SELECT run_id, mode, status, created_at, ended_at, title, input_summary
                     FROM runs
@@ -194,7 +194,7 @@ class SQLiteRunStore:
                     (mode, limit, offset),
                 )
             else:
-                rows = await db.execute_fetchall(
+                cursor = await db.execute(
                     """
                     SELECT run_id, mode, status, created_at, ended_at, title, input_summary
                     FROM runs
@@ -203,6 +203,7 @@ class SQLiteRunStore:
                     """,
                     (limit, offset),
                 )
+            rows = await cursor.fetchall()
 
         return [
             RunSummary(
@@ -220,7 +221,7 @@ class SQLiteRunStore:
     async def get_run(self, run_id: str) -> Optional[RunRecord]:
         async with aiosqlite.connect(self.db_path) as db:
             await db.execute("PRAGMA foreign_keys=ON;")
-            row = await db.execute_fetchone(
+            cursor = await db.execute(
                 """
                 SELECT run_id, mode, status, created_at, ended_at, title, input_summary, config_json, sealed_at
                 FROM runs
@@ -228,10 +229,11 @@ class SQLiteRunStore:
                 """,
                 (run_id,),
             )
+            row = await cursor.fetchone()
             if not row:
                 return None
 
-            message_rows = await db.execute_fetchall(
+            cursor = await db.execute(
                 """
                 SELECT message_index, role, persona_label, content, timestamp
                 FROM run_messages
@@ -240,7 +242,9 @@ class SQLiteRunStore:
                 """,
                 (run_id,),
             )
-            analysis_rows = await db.execute_fetchall(
+            message_rows = await cursor.fetchall()
+
+            cursor = await db.execute(
                 """
                 SELECT analysis_key, result_json
                 FROM run_analyses
@@ -248,7 +252,9 @@ class SQLiteRunStore:
                 """,
                 (run_id,),
             )
-            snapshot_rows = await db.execute_fetchall(
+            analysis_rows = await cursor.fetchall()
+
+            cursor = await db.execute(
                 """
                 SELECT role, persona_id, persona_version_id, snapshot_json
                 FROM run_persona_snapshots
@@ -256,6 +262,7 @@ class SQLiteRunStore:
                 """,
                 (run_id,),
             )
+            snapshot_rows = await cursor.fetchall()
 
         messages: List[Dict[str, Any]] = []
         for (idx, role, persona, content, ts) in message_rows:
@@ -307,4 +314,3 @@ class SQLiteRunStore:
             analyses=analyses,
             persona_snapshots=persona_snapshots,
         )
-