Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

airflow.providers.celery.cli.celery_command

Celery command.

Attributes

WORKER_PROCESS_NAME

log

Functions

flower(args)

Start Flower, Celery monitoring tool.

logger_setup_handler(logger, **kwargs)

Reconfigure the logger.

worker(args)

Start Airflow Celery worker.

stop_worker(args)

Send SIGTERM to Celery worker.

list_workers(args)

List all active celery workers.

shutdown_worker(args)

Request graceful shutdown of a celery worker.

shutdown_all_workers(args)

Request graceful shutdown all celery workers.

add_queue(args)

Subscribe a Celery worker to specified queues.

remove_queue(args)

Unsubscribe a Celery worker from specified queues.

Module Contents

airflow.providers.celery.cli.celery_command.WORKER_PROCESS_NAME = 'worker'[source]
airflow.providers.celery.cli.celery_command.log[source]
airflow.providers.celery.cli.celery_command.flower(args)[source]

Start Flower, Celery monitoring tool.

airflow.providers.celery.cli.celery_command.logger_setup_handler(logger, **kwargs)[source]

Reconfigure the logger.

  • remove any previously configured handlers

  • logs of severity error, and above goes to stderr,

  • logs of severity lower than error goes to stdout.

airflow.providers.celery.cli.celery_command.worker(args)[source]

Start Airflow Celery worker.

airflow.providers.celery.cli.celery_command.stop_worker(args)[source]

Send SIGTERM to Celery worker.

airflow.providers.celery.cli.celery_command.list_workers(args)[source]

List all active celery workers.

airflow.providers.celery.cli.celery_command.shutdown_worker(args)[source]

Request graceful shutdown of a celery worker.

airflow.providers.celery.cli.celery_command.shutdown_all_workers(args)[source]

Request graceful shutdown all celery workers.

airflow.providers.celery.cli.celery_command.add_queue(args)[source]

Subscribe a Celery worker to specified queues.

airflow.providers.celery.cli.celery_command.remove_queue(args)[source]

Unsubscribe a Celery worker from specified queues.

Was this entry helpful?