Difference between revisions of "Airflow celery worker"

From wikieduonline
Jump to navigation Jump to search
Line 10: Line 10:
 
  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.
 
  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]]
+
  Solution: change [[executor]] in [[airflow.cfg]] to [[CeleryExecutor]]
  
 
== Related ==
 
== Related ==

Revision as of 11:04, 20 December 2022


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: