async def db_session(db_engine) -> AsyncGenerator[AsyncSession, None]:
    """Create a new database session for integration tests.

    Each test gets a fresh session with complete cleanup.
    """
    async with AsyncSession(db_engine, expire_on_commit=False) as session:
        yield session
        # The context manager automatically handles cleanup
Create a new database session for integration tests.

    Each test gets a fresh session with complete cleanup.
    
backend/tests/conftest.py