Technologies/Dramatiq/dramatiq.message.lag
DramatiqDramatiqMetric

dramatiq.message.lag

Time from enqueue to processing
Dimensions:None
Available on:OpenTelemetryOpenTelemetry (1)
Interface Metrics (1)
OpenTelemetryOpenTelemetry
Time between message enqueue and processing start
Dimensions:None
Sources
dramatiq.message.laggithub.com

Technical Annotations (6)

Configuration Parameters (1)
worker_timeoutrecommended: 100
Polling interval in milliseconds when queue is idle; lower values reduce task pickup latency (default is 1000)
Technical References (5)
time.sleepcomponentkafka providercomponentWorkercomponentcli.pyfile pathworker_processcomponent
Related Insights (2)
Millisecond to second conversion bug causes 1000x longer retry delayscritical
▸
High worker timeout causes task pickup latency when queue is idlewarning
▸