Function clickhouse_delete_span

app/api/agentops/exporter/processor.py:437–448

Delete a span from ClickHouse by SpanId

(span_id: Any)

async def clickhouse_delete_span(span_id: Any) -> None:
    """Delete a span from ClickHouse by SpanId"""
    client = await get_async_clickhouse()
    query = """
    ALTER TABLE {table_name} 
    DELETE WHERE SpanId = '{span_id}'
    """
    query = query.format(table_name=IMPORT_TABLE_NAME, span_id=str(span_id))
    if not DRY_RUN:
        await client.query(query)
    else:
        print(query)


async def clickhouse_update_span(span_id: str, update_data: dict) -> None: