Airflow:如何删除 DAG？

Question

我已经启动了 Airflow 网络服务器并安排了一些 dags。我可以在 Web GUI 上看到这些 dags。

如何删除正在运行并在 Web GUI 中显示的特定 DAG？有 Airflow CLI 命令可以做到这一点吗？

我环顾四周，但找不到在加载和计划 DAG 后删除它的简单方法的答案。

Answer 1

编辑 2018 年 8 月 27 日 - Airflow 1.10 现已在 PyPI 上发布!

https://pypi.org/project/apache-airflow/1.10.0/

<小时/>

如何彻底删除DAG

我们现在在 Airflow ≥ 1.10 中拥有此功能!

公关#2199 (Jira: AIRFLOW-1002 )将 DAG 删除添加到 Airflow 现已合并，允许从所有相关表中完全删除 DAG 条目。

核心delete_dag(...)代码现在是实验性 API 的一部分，并且有可用的入口点 via the CLI还有via the REST API .

命令行界面:

airflow delete_dag my_dag_id

REST API(本地运行网络服务器):

curl -X "DELETE" http://127.0.0.1:8080/api/experimental/dags/my_dag_id

<小时/>

有关 REST API 的警告:确保您的 Airflow 集群 uses authentication正在生产中。

安装/升级到 Airflow 1.10(当前)

要升级，请运行:

export SLUGIFY_USES_TEXT_UNIDECODE=yes

或者:

export AIRFLOW_GPL_UNIDECODE=yes

然后:

pip install -U apache-airflow

记得查看UPDATING.md首先了解完整的详细信息!