task Deduplication · medium

Audit conflicting event retries

Report only retried event keys. Return event_key, the smallest id as canonical_id, the event_type from that canonical row as canonical_type, and the number of additional ingestion rows as retry_count.

what to return

Columns

event_keycanonical_idcanonical_typeretry_count in this order

Rows

2 rows · in the order asked

Watch for

Deduplicate globally by event_key, keeping the smallest id; a retry may have a conflicting payload.

Use (occurred_at, id) as the total event order; equal timestamps follow id order. All times are UTC.

Count all retry rows even when their payload differs. Order by event_key.

Skill

Separate logical event identity from ingestion row identity. Refresher: Sessionize an event stream →

expected result

Your query should return exactly these columns and values. Run it and compare.

data you can query

Sample rows from each table. Each column shows its type underneath; → marks a link to another table.