airflow.providers.celery.cli.celery_command

Celery command.

Module Contents

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.

Attributes

WORKER_PROCESS_NAME

airflow.providers.celery.cli.celery_command.WORKER_PROCESS_NAME = 'worker'[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.

Was this entry helpful?