Difference between revisions of "Airflow celery worker"

From wikieduonline
Jump to navigation Jump to search
Line 6: Line 6:
  
  
 
+
== Errors ==
 
  [[airflow celery]] worker
 
  [[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.
 
  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.

Revision as of 11:04, 20 December 2022


airflow celery worker
airflow celery worker -q yourqueue1,yourqueue2


Errors

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: