dramatiq.messages.delayed.inprogress

Delayed messages scheduled

Dimensions:None

Technical Annotations (15)

Configuration Parameters (3)

bucket_sizerecommended: 2x expected peak

prevents depletion during burst traffic

fill_raterecommended: adaptive based on queue length

tokens replenished per second, adjust dynamically

DEFAULT_MAX_BACKOFFrecommended: 30 minutes or less

Maximum backoff delay to prevent consumer timeout in DQ thread

CLI Commands (2)

redis-cli HGETALL "dramatiq:default.msgs"diagnostic

redis-cli SMEMBERS "dramatiq:__acks__.{worker_id}.{queue}"diagnostic

Technical References (10)

DQ consumer threadcomponentDelayed Deliverycomponentredis_message_idconceptmessage_idconceptWorkerThreadcomponentdramatiq:default.msgscomponent*.DQcomponentworker.pyfile pathConsumerThreadcomponenthandle_delayed_messagescomponent

Related Insights (5)

Token bucket depletion starves queues during burst trafficwarning

▸

Delayed messages exceeding consumer timeout cause queue churnwarning

▸

High prefetch limit for delayed messages risks memory exhaustionwarning

▸

Delayed messages duplicated with same message_id but different redis_message_idscritical

▸

Race condition between delayed message copy and acknowledgmentcritical

▸