airflow celery worker

From wikieduonline
Revision as of 11:04, 20 December 2022 by Ant (talk | contribs)
Jump to navigation Jump to search


airflow celery worker
airflow celery worker -q yourqueue1,yourqueue2


airflow celery worker
airflow command error: argument GROUP_OR_COMMAND: celery subcommand works only with CeleryExecutor, CeleryKubernetesExecutor and executors derived from them, your current executor: SequentialExecutor, subclassed from: BaseExecutor, see help above.

Solution: change executor in airflow.cfg to CeleryExecutor

Related

celery worker

See also

Advertising: