Coverage for app / db / session.py: 100%

1from sqlalchemy import create_engine 

2from sqlalchemy.orm import sessionmaker 

3from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine 

4 

5from app.core.config import settings 

6 

7# Async engine for FastAPI 

8async_engine = create_async_engine(settings.database_url, echo=True) 

9AsyncSessionLocal = async_sessionmaker(async_engine, expire_on_commit=False) 

10 

11# Sync engine for Celery workers 

12sync_engine = create_engine(settings.sync_database_url, echo=True) 

13SyncSessionLocal = sessionmaker(sync_engine, expire_on_commit=False)