Dashboardsentryprocessors.py event_accepted signal: 9 …

processors.py event_accepted signal: 9 skip conditions and dedup layering

Category: pattern
Confidence: 0.80
ID: 019fb3f0-a688-7e9b-a65b-a6b63074f953
Project ID: 702228c8-56bc-4694-8d5a-174ac2f29105
Cross-project: No
Recalled in other projects: 1
Source session: 0rWXqG93IDSIFMxki
Created: 2026-07-30 15:52:16
Updated: 2026-07-30 16:52:00

Cross-Project Recalls

ProjectHitsLast recalled
opencode 1 9d ago

Content

In src/sentry/ingest/consumer/processors.py, event_accepted.send_robust() (lines 313-316) is skipped by 9 paths: (1) cache dedup hit at l.117-131 (ev:{project_id}:{event_id}, ~1h TTL), (2) store.load-shed-pipeline-projects kill switch (l.144), (3) orjson.loads failure OUTSIDE try block (l.150 — propagates unhandled, not wrapped as Retriable), (4) store.load-shed-parsed-pipeline-projects kill switch (l.175), (5) reprocess_only_stuck_events + missing from processing_store (l.188), (6) reprocess_only_events_not_in_nodestore + event IS in nodestore (l.192-196, d7fcb07bc42), (7) Organization.DoesNotExist (l.246), (8) client_ip filter (l.232), (9) any exception in try block — caught at l.317 and re-raised as Retriable. Trap: dedup cache catches most repeats; the reprocess flag is the SECOND filter, only catching dedup-escapees. send_robust swallows receiver exceptions. event_accepted semantically means "saved" not "seen"; consumers needing all traffic must use Kafka directly.

Move to: