# HELP celery_task_sent_total Sent when a task message is published.
# TYPE celery_task_sent_total counter
# HELP celery_task_received_total Sent when the worker receives a task.
# TYPE celery_task_received_total counter
# HELP celery_task_started_total Sent just before the worker executes the task.
# TYPE celery_task_started_total counter
# HELP celery_task_succeeded_total Sent if the task executed successfully.
# TYPE celery_task_succeeded_total counter
# HELP celery_task_failed_total Sent if the execution of the task failed.
# TYPE celery_task_failed_total counter
# HELP celery_task_rejected_total The task was rejected by the worker, possibly to be re-queued or moved to a dead letter queue.
# TYPE celery_task_rejected_total counter
# HELP celery_task_revoked_total Sent if the task has been revoked.
# TYPE celery_task_revoked_total counter
# HELP celery_task_retried_total Sent if the task failed, but will be retried in the future.
# TYPE celery_task_retried_total counter
# HELP celery_worker_up Indicates if a worker has recently sent a heartbeat.
# TYPE celery_worker_up gauge
celery_worker_up{hostname="fd829d6fb83b"} 1.0
celery_worker_up{hostname="9259410e9b77"} 1.0
celery_worker_up{hostname="f5f8948e1979"} 1.0
celery_worker_up{hostname="09c4d85a7213"} 1.0
celery_worker_up{hostname="438c0ae9ee1d"} 1.0
# HELP celery_worker_tasks_active The number of tasks the worker is currently processing
# TYPE celery_worker_tasks_active gauge
celery_worker_tasks_active{hostname="fd829d6fb83b"} 0.0
celery_worker_tasks_active{hostname="9259410e9b77"} 0.0
celery_worker_tasks_active{hostname="f5f8948e1979"} 0.0
celery_worker_tasks_active{hostname="09c4d85a7213"} 0.0
celery_worker_tasks_active{hostname="438c0ae9ee1d"} 0.0
# HELP celery_task_runtime Histogram of task runtime measurements.
# TYPE celery_task_runtime histogram
# HELP celery_queue_length The number of message in broker queue.
# TYPE celery_queue_length gauge
celery_queue_length{queue_name="integration"} 0.0
celery_queue_length{queue_name="pipeline"} 0.0
celery_queue_length{queue_name="ranking"} 0.0
celery_queue_length{queue_name="enrichment"} 0.0
celery_queue_length{queue_name="default"} 0.0
celery_queue_length{queue_name="persistence"} 0.0
# HELP celery_active_consumer_count The number of active consumer in broker queue.
# TYPE celery_active_consumer_count gauge
# HELP celery_active_worker_count The number of active workers in broker queue.
# TYPE celery_active_worker_count gauge
celery_active_worker_count{queue_name="integration"} 1.0
celery_active_worker_count{queue_name="pipeline"} 1.0
celery_active_worker_count{queue_name="ranking"} 1.0
celery_active_worker_count{queue_name="enrichment"} 1.0
celery_active_worker_count{queue_name="default"} 1.0
celery_active_worker_count{queue_name="persistence"} 1.0
# HELP celery_active_process_count The number of active processes in broker queue.
# TYPE celery_active_process_count gauge
celery_active_process_count{queue_name="integration"} 2.0
celery_active_process_count{queue_name="pipeline"} 2.0
celery_active_process_count{queue_name="ranking"} 2.0
celery_active_process_count{queue_name="enrichment"} 4.0
celery_active_process_count{queue_name="default"} 2.0
celery_active_process_count{queue_name="persistence"} 2.0