我正在使用这个compose文件来运行带有芹菜执行器的Airflow:芹菜执行器。yaml档案中也有一个鲜花服务,用来监督工人。我想为工作人员添加队列。当我按原样运行docker compose文件时,我可以在flower的UI上看到工人。当我将工作者服务的命令标签从";工人;至";worker-q worker_subdag,默认值"似乎没有工作人员在flower的UI中运行。
command: worker -q worker_subdag, default
我也尝试了以下命令,但没有成功:
airflow worker -q worker_subdag, default
airflow celery worker -q worker_subdag, default
celery worker -q worker_subdag, default
不要使用命令中的-Q
标志设置队列,而是在docker compose:的环境部分设置它
environment:
<<: *airflow-common-env
DUMB_INIT_SETSID: "0"
AIRFLOW__OPERATORS__DEFAULT_QUEUE: worker_subdag