Dependency to get database session.
()
| 37 | |
| 38 | |
| 39 | async def get_db() -> AsyncSession: |
| 40 | """Dependency to get database session.""" |
| 41 | async with async_session_maker() as session: |
| 42 | try: |
| 43 | yield session |
| 44 | await session.commit() |
| 45 | except Exception: |
| 46 | await session.rollback() |
| 47 | raise |
| 48 | finally: |
| 49 | await session.close() |
| 50 | |
| 51 | |
| 52 | async def init_db(): |