Ensures we await committing after creating the table but before adding the trigger.

thewhaleking · thewhaleking · commit f85b194b64f4 · 2026-02-03T19:09:51.000+02:00
diff --git a/async_substrate_interface/utils/cache.py b/async_substrate_interface/utils/cache.py
@@ -61,6 +61,7 @@ async def _create_if_not_exists(self, chain: str, table_name: str):
                     );
                 """
             )
+            await self._db.commit()
             await self._db.execute(
                 f"""
                 CREATE TRIGGER IF NOT EXISTS prune_rows_trigger_{table_name} AFTER INSERT ON {table_name}

Original file line number	Diff line number	Diff line change
`@@ -61,6 +61,7 @@ async def _create_if_not_exists(self, chain: str, table_name: str):`
`61`	`61`	`);`
`62`	`62`	`"""`
`63`	`63`	`)`
	`64`	`+ await self._db.commit()`
`64`	`65`	`await self._db.execute(`
`65`	`66`	`f"""`
`66`	`67`	`CREATE TRIGGER IF NOT EXISTS prune_rows_trigger_{table_name} AFTER INSERT ON {table_name}`