(self)
| 91 | |
| 92 | @asynccontextmanager |
| 93 | async def get_tracing_session(self) -> AsyncGenerator[AsyncSession, None]: |
| 94 | session = self.async_tracing_session() |
| 95 | try: |
| 96 | yield session |
| 97 | except Exception as e: |
| 98 | await session.rollback() |
| 99 | raise e |
| 100 | finally: |
| 101 | await session.close() |
| 102 | |
| 103 | async def close_db(self): |
| 104 | """ |