celery.queue.consumers

Connected queue consumers

Dimensions:None

Technical Annotations (11)

Configuration Parameters (2)

worker_prefetch_multiplierrecommended: 1

configuration mentioned in deployment details, may affect task queueing behavior

broker_connection_retryrecommended: False

workaround to make worker crash on broker loss, requires restart policy

Error Signatures (1)

Task requeue attempts exceeded max; marking failedlog pattern

CLI Commands (2)

celery inspect pingdiagnostic

celery inspect active_queuesdiagnostic

Technical References (6)

catatonic stateconceptconsumer registrationconcepttransport levelconceptCeleryExecutorcomponentairflow-providers-celerycomponentrequeue limitconcept

Related Insights (2)

Celery worker enters catatonic state after Redis broker restartcritical

▸

Airflow health check fails to detect Celery worker queue consumer losscritical

▸