airflow.providers.celery.cli.celery_command¶
Celery command.
Attributes¶
Functions¶
|
Start Flower, Celery monitoring tool. |
|
Reconfigure the logger. |
|
Start Airflow Celery worker. |
|
Send SIGTERM to Celery worker. |
|
List all active celery workers. |
|
Request graceful shutdown of a celery worker. |
|
Request graceful shutdown all celery workers. |
|
Subscribe a Celery worker to specified queues. |
|
Unsubscribe a Celery worker from specified queues. |
Module Contents¶
- 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.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.