Product Agent MCP Server

from __future__ import annotations import os from typing import AsyncIterator from sqlalchemy.ext.asyncio import ( AsyncSession, create_async_engine, async_sessionmaker, ) from sqlalchemy.orm import DeclarativeBase DATABASE_URL = os.getenv("DATABASE_URL", "sqlite+aiosqlite:///./data/app.db") engine = create_async_engine(DATABASE_URL, echo=False, future=True) SessionLocal = async_sessionmaker(engine, class_=AsyncSession, expire_on_commit=False) class Base(DeclarativeBase): pass async def get_session() -> AsyncIterator[AsyncSession]: async with SessionLocal() as session: yield session