diff --git a/packages/db/src/queries/submissions.ts b/packages/db/src/queries/submissions.ts index 775e5bf..3b526b9 100644 --- a/packages/db/src/queries/submissions.ts +++ b/packages/db/src/queries/submissions.ts @@ -19,7 +19,8 @@ export interface SubmissionVolumeRow { datapoints: number; } -/** Get unique config submissions with first/latest date and datapoint counts. */ +/** Get unique config submissions with first/latest date and datapoint counts. + * Uses latest_benchmarks (deduplicated: newest per config+conc+isl+osl, no errors). */ export async function getSubmissionSummary(sql: DbClient): Promise { const rows = await sql` SELECT @@ -36,39 +37,34 @@ export async function getSubmissionSummary(sql: DbClient): Promise { const rows = await sql` SELECT - br.date::text, + lb.date::text, c.hardware, COUNT(*)::int AS datapoints - FROM benchmark_results br - JOIN configs c ON c.id = br.config_id - JOIN latest_workflow_runs wr ON wr.id = br.workflow_run_id - WHERE br.error IS NULL - AND wr.conclusion IS NOT NULL - GROUP BY br.date, c.hardware - ORDER BY br.date ASC + FROM latest_benchmarks lb + JOIN configs c ON c.id = lb.config_id + GROUP BY lb.date, c.hardware + ORDER BY lb.date ASC `; return rows as unknown as SubmissionVolumeRow[]; }