• Home
• airflow.providers.celery
• airflow.providers.celery.cli
• airflow.providers.celery.cli.celery_command

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.

Module Contents

airflow.providers.celery.cli.celery_command.WORKER_PROCESS_NAME = 'worker'

airflow.providers.celery.cli.celery_command.log

airflow.providers.celery.cli.celery_command.flower(args)

Start Flower, Celery monitoring tool.

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

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)

Start Airflow Celery worker.

airflow.providers.celery.cli.celery_command.stop_worker(args)

Send SIGTERM to Celery worker.

Previous Next

Was this entry helpful?