我确实正确配置了我的airflow.cfg。我确实将executor值设置为CeleryExecutor (这不意味着我已经设置了executor值)。我的airflow.cfg如下:注意:我只是添加一些我认为与问题相关的配置。# The concurrency that will be used when starting workers with the
# ``airflow celery worker`` commanduserguide/configuration.html#task-result-backend-set
Airflow scheduler正在根据airflow.cfg文件中的设置从正确的文件夹中提取dags。但是,Airflowui the服务器正在从错误的文件夹中选取dags。我通过查看运行airflow via服务器的终端的stdout实现了这一点:[2018-10-08 14:26:48,519] [15535] {models.py:167} INFO - Fillingup the DagBag from /home/aviral/airflow
by the UI.by the UI., which is needed by the UI.' from 'apache-airflow-providers-google' package/home/airflow/.local[api] has had airflow.api.auth.backend.session added in th
我从airflow dag_bag和相应的.pyc文件中删除了dag。当我尝试从airflowUI中删除相同的dag时,它显示此错误: Dag id MY_DAG_ID仍然在DagBag中。我使用的airflow版本是1.10.4,即使在重新启动airflow之后,我也无法从UI中删除。我之前使用的是1.10.3,但我从未遇到过这个问题。在从dags文件夹中删除后,我可以从UI中删除。当我点击UI中的dag时,它显示: DAG "MY_DA