symfonic.core.observability.postgres_metrics_store

postgres_metrics_store

Postgres persistence for billable calls and safe execution metadata.

PostgresMetricsStore

PostgresMetricsStore(session_factory: SessionFactory)

Durable :class:MetricsStore backed by the llm_calls table.

Source code in src/symfonic/core/observability/postgres_metrics_store.py

def __init__(self, session_factory: SessionFactory) -> None:
    self._session_factory = session_factory

record_events async

record_events(rows: list[dict[str, Any]]) -> None

Persist safe execution metadata separately from billable calls.

Source code in src/symfonic/core/observability/postgres_metrics_store.py

async def record_events(self, rows: list[dict[str, Any]]) -> None:
    """Persist safe execution metadata separately from billable calls."""
    if not rows:
        return
    async with self._open() as session:
        await session.execute(_text(INSERT_EVENT_SQL), rows)
        await session.commit()