(self)
| 19 | self._initialized = False |
| 20 | |
| 21 | async def prepare(self) -> None: |
| 22 | if self._initialized: |
| 23 | return |
| 24 | engine, self.meta_cls, self.blob_cls = await init_async_engine( |
| 25 | db_url=self._db_url, |
| 26 | table_name=self._table_name, |
| 27 | schema_type="experience", |
| 28 | ) |
| 29 | self.session = async_sessionmaker(engine, expire_on_commit=False) |
| 30 | self._initialized = True |
| 31 | self.logger.info(f"Init async SQL storage at {self._db_url}") |
| 32 | |
| 33 | async def record_history(self, experiences: List[Experience]) -> None: |
| 34 | """Save experiences to the database.""" |
no test coverage detected