Function aggregate 

pub fn aggregate(
    corpus_name: &str,
    service_name: &str,
    sandbox_id: Option<i32>,
    entries: Vec<String>,
) -> TelemetrySummary

Aggregates the telemetry of a completed run: reads each task entry’s result-archive telemetry.json in parallel (a bounded std::thread::scope pool, N = available_parallelism capped at 16, the entries chunked evenly across threads), skipping any archive that is missing / unreadable / lacks a telemetry record, then summarizes. sandbox_id is threaded through result_archive_path so a sandbox corpus reads its own name-scoped archives, not the parent’s.