WORLD
RECORD
EVIDENCE

-- Returns live classification total
SELECT key, value, updated_at
FROM mgn_stats_cache
ORDER BY key;

-- Returns exact pipeline start (first ingest run)
SELECT MIN(started_at) AS pipeline_start
FROM mgn_ingest_log
WHERE started_at >= '2026-04-17 00:00:00+00';
-- Expected: 2026-04-20 01:30:03.077596+00

-- Calculates exact elapsed time from pipeline start to 1M
SELECT
  EXTRACT(EPOCH FROM (
    '2026-04-20 14:00:19.669+00'::timestamptz -
    '2026-04-20 01:30:03+00'::timestamptz
  ))/3600 AS elapsed_hours;
-- Expected: 12.5046 hours (12h 30m 16s)

-- Lists all source families with record counts
SELECT
  SPLIT_PART(source_slug, '-', 1) AS source_family,
  COUNT(*) AS runs,
  SUM(records_minted) AS minted
FROM mgn_ingest_log
WHERE started_at BETWEEN
  '2026-04-20 01:30:00+00' AND
  '2026-04-20 14:00:20+00'
  AND status IN ('SUCCESS','PARTIAL')
  AND records_minted > 0
GROUP BY source_family
ORDER BY minted DESC;

-- Counts distinct taxonomic categories
SELECT
  COUNT(DISTINCT canonical_code) AS distinct_codes,
  COUNT(DISTINCT domain) AS distinct_domains,
  COUNT(DISTINCT subdomain) AS distinct_subdomains
FROM mgn_classifications;
-- Expected: 7757 codes, 11 domains, 84 subdomains