我也从气流dag_bag和相应的.pyc文件中删除了dag。当我尝试从气流 UI 中删除相同的 dag 时,它显示此错误: Dag ID MY_DAG_ID 仍在 DagBag 中。首先删除 DAG 文件。 我使用的气流版本是 1.10.4 即使在重新启动气流后,我也无法从UI中删除。我以前使用过 1.10.3,但我从未遇到过这个问题。从 dags 文件夹中删除后,我能够从 UI 中删除。
当我在UI中单击该dag时,它显示: DAG"MY_DAG_ID"似乎不见了。(这是我从文件夹中删除了dag时预期的(
尝试停止调度程序和 Web 服务器,然后从命令行中删除 DAG:
airflow delete_dag 'MY_DAG_ID'
升级到 1.10.6 后我遇到了同样的问题。这是我所做的:
- 在删除 DAG 之前,请确保没有实例处于正在运行状态,重试状态。然后暂停它
- 在 UI 上删除或使用命令
airflow delete_dag dag_id
- 重新启动调度程序和 Web 服务器
- 尝试执行
airflow list_dags
以查看它是否真的被删除了。
如果不起作用,请尝试升级到最新版本。