feat(snuba): Implement alternative pull-based Snuba(hackweek) - #8355

Merged

tryangul merged 20 commits into

rbroughan/pull-snuba

Aug 20, 2026

Commits on Aug 20, 2026

Wire up basic processor stage and tests.
tryangul
committed
423a604
Initial Batch stage impl.
tryangul
committed
87dd8e2
Refactor to pipeline struct with test collector
tryangul
committed
6f43061
Add batch timer and CH stages.
tryangul
committed
f850cde
Add PipelineBatch to fix batching
tryangul
committed
671a9ad
Switch to object safe CH writer.
tryangul
committed
37a34af
BatchMetadata flows from the writer so we drop the bytes
tryangul
committed
797e305
Factor out separate pipelines for EAP and easy ones. Wire up.
tryangul
committed
af3735a
DryRunProducer.
tryangul
committed
82db6da
Wire it up dirty style.
tryangul
committed
f9a199a
Use arroyo branch as dep. Fix source wiring. Remove unused NoopStage.
tryangul
committed
fe192ea
dry run latency is now configurable
tryangul
committed
7eb6574
Processing stage is now concurrent
tryangul
committed
b373c63
Processing stage is now concurrent and properly rejects unprocessable messages instead of failing the pipeline
tryangul
committed
10ef995
Fix offset / timestamp tracking.
tryangul
committed
499fc68
Fix lint errors.
tryangul
committed
b32c997
Add GoCD container names
tryangul
committed
54145b2
Properly Drop SilencedDLQMessage.
tryangul
committed
3829dc5
Remove PolymorphicMetricsProcessor from fire and forget processors since its pipeline writes to the commit log
tryangul
committed
9112f90
Add back sts support.
tryangul
committed
591aad6