Summary
The DeliveryWorker (background Redis Streams consumer for async message delivery) is implemented but not yet started in the app lifespan.
TODO
- Start the delivery worker in
main.py lifespan alongside the event consumer and scheduler
- Wire channel service to enqueue deliveries to the worker instead of doing inline HTTP delivery
- Add integration tests for delivery retry and backoff behavior
- Add delivery metrics/logging for observability
Files
src/network/utils/delivery_worker.py — worker implementation
src/main.py — needs lifespan integration
src/network/services/channels.py — currently does inline delivery, should optionally enqueue
Summary
The
DeliveryWorker(background Redis Streams consumer for async message delivery) is implemented but not yet started in the app lifespan.TODO
main.pylifespan alongside the event consumer and schedulerFiles
src/network/utils/delivery_worker.py— worker implementationsrc/main.py— needs lifespan integrationsrc/network/services/channels.py— currently does inline delivery, should optionally enqueue