admin管理员组

文章数量:1125579

I have Airflow (v2.10.4) deployed on k8s, with the git-sync sidecar, which populates the dags PVC. After doing some refactoring of the DAGs, the Airflow UI reports 1 DAG Import Error:

Broken DAG: [/opt/airflow/dags/repo/dags/utils/callbacks.py]
Traceback (most recent call last):
  File "<frozen importlib._bootstrap>", line 241, in _call_with_frames_removed
  File "/opt/airflow/dags/repo/dags/utils/callbacks.py", line 4, in <module>

The file in question (callbacks.py) was deleted and is no longer in git and also no longer in the mounted dags volume. I checked on the scheduler pod:

$ ls /opt/airflow/dags/repo/dags/utils/callbacks.py
ls: cannot access '/opt/airflow/dags/repo/dags/utils/callbacks.py': No such file or directory

Does the webserver pod or anything else in Airflow keep a local copy or something? Maybe in the DB? How can I clear this error?

本文标签：

版权声明：本文标题：Airflow: DAG Import Error for deleted file - Stack Overflow 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.betaflare.com/web/1736663471a1946536.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。