PersonalPublic/fastapi-sqlalchemy-asyncpg
1
0
Fork 0
mirror of https://github.com/grillazz/fastapi-sqlalchemy-asyncpg.git synced 2025-08-26 16:40:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

69-unnecessary-method

Browse Source
This commit is contained in:
Jakub Miazek 2023-01-17 20:57:50 +01:00
parent 02525817fc
commit efadedaab0
1 changed files with 0 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
app/database.py
View File

@ -32,19 +32,3 @@ async def get_db() -> AsyncGenerator:
logger.debug(f"ASYNC Pool: {engine.pool.status()}") logger.debug(f"ASYNC Pool: {engine.pool.status()}")
yield session yield session
async def get_async_db() -> AsyncGenerator:
try:
session: AsyncSession = AsyncSessionFactory()
logger.debug(f"ASYNC Pool: {engine.pool.status()}")
yield session
except SQLAlchemyError as sql_ex:
await session.rollback()
raise sql_ex
except HTTPException as http_ex:
await session.rollback()
raise http_ex
else:
await session.commit()
finally:
await session.close()