feat: replace Redis queue with Postgres-native atomic job ownership - #582

Open

acardace wants to merge 16 commits into

acardace:feat/postgres-job-queue

Commits on Aug 10, 2026

postgresql: change extra column values from string to any
acardace
committed
ed7b749
postgresql: add processor_id and priority columns to batch_items
acardace
committed
ec7fa2a
postgresql: implement BatchPriorityQueueClient backed by batch_items table
acardace
committed
1960f16
clientset: wire Postgres queue client for postgresql DB backend
acardace
committed
5c8c88e
worker: add DB-based startup recovery by processor_id
acardace
committed
19abdee
gc: add Kubernetes pod watcher for processor StatefulSet
acardace
committed
6c7e753
converter: populate Priority field from CompletionWindow and CreatedAt
acardace
committed
dd3204e
helm: switch processor from Deployment to StatefulSet
acardace
committed
cadefc3
Migrate SLO from tags to Priority column
acardace
committed
8e42264
Remove Redis InFlight tracking and heartbeat mechanism
acardace
committed
2d3a3fb
Remove Redis BatchDBClient and FileDBClient
acardace
committed
2beac5d
fix(e2e): prevent deadlock in waitForProcessorReady after pod restart
acardace
committed
2e9eb31
fix(e2e): restore sim latency after rollout restart completes
acardace
committed
a57c0c3
fix(apiserver): handle PQDelete cancel-from-queue atomically
acardace
committed
789b108
fix(gc): transition cancelling orphans to cancelled instead of re-enqueueing
acardace
committed
9a00e71
feat: add epoch-based fencing to prevent zombie processor writes
acardace
committed
7758208