Difference between revisions of "Airflow celery worker"

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

Revision as of 11:03, 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

Related

celery worker

See also

Advertising: