在进行airflow分布式调用时出现worker在master flower中未显示的问题

经查证大多数时未正常启动worker的问题

查看worker.error

发现未有root权限设置

因使用celery 执行代码

 so

需要在celery_executor.py中强制设置C_FORCE_ROOT

 linux 查找celery_executor.py

from celery import Celery, platforms 
	在app = Celery(…)后新增 
	platforms.C_FORCE_ROOT = True