Function count_v2_sourced_rows

app/api/agentops/exporter/processor.py:349–357

Count the number of rows in the v2 sourced table

()

async def count_v2_sourced_rows() -> int:
    """Count the number of rows in the v2 sourced table"""
    clickhouse_client = await get_async_clickhouse()
    query = """
    SELECT COUNT(1) FROM otel_2.otel_traces
    WHERE mapContains(SpanAttributes, 'session.id')
    """
    result = await clickhouse_client.query(query)
    return result.result_rows[0][0]


class _ClickhouseDriverContextShim: