我已经启动了Airflow网络服务器,并安排了一些调试工作。我可以在Web GUI上看到这些问题。
I have started the Airflow webserver and scheduled some dags. I can see the dags on web GUI.
如何删除正在运行并显示在Web GUI中的特定DAG?
How can I delete a particular DAG from being run and shown in web GUI? Is there an Airflow CLI command to do that?
我环顾四周,但找不到加载DAG并计划好删除DAG的简单方法的答案。
I looked around but could not find an answer for a simple way of deleting a DAG once it has been loaded and scheduled.
推荐答案编辑8/27/18-Airflow 1.10现在已在PyPI上发布!
pypi/ project / apache-airflow / 1.10.0 /
我们现在在Airflow≥1.10中具有此功能!
We have this feature now in Airflow ≥ 1.10!
PR #2199 (吉拉: AIRFLOW-1002 )现在已合并到Airflow中添加了DAG删除功能,从而可以从所有相关表中完全删除DAG的条目。
The PR #2199 (Jira: AIRFLOW-1002) adding DAG removal to Airflow has now been merged which allows fully deleting a DAG's entries from all of the related tables.
核心 delete_dag(...)代码现在是实验性API的一部分,并且有可用的入口点href = github/apache/incubator-airflow/blob/9dba430b683361fc0ed7f50de6daa03c971a476b/airflow/bin/cli.py#L214-L232 rel = noreferrer>通过CLI 以及通过REST API 。
The core delete_dag(...) code is now part of the experimental API, and there are entrypoints available via the CLI and also via the REST API.
CLI:
airflow delete_dag my_dag_idREST API(本地运行网络服务器):
REST API (running webserver locally):
curl -X "DELETE" 127.0.0.1:8080/api/experimental/dags/my_dag_id
关于REST API的警告:确保您的Airflow集群在生产中使用身份验证。
Warning regarding the REST API: Ensure that your Airflow cluster uses authentication in production.
要升级,请运行:
export SLUGIFY_USES_TEXT_UNIDECODE=yes或:
export AIRFLOW_GPL_UNIDECODE=yes然后:
pip install -U apache-airflow记住要检查 UPDATING.md 首先了解全部细节!
Remember to check UPDATING.md first for the full details!
更多推荐
气流:如何删除DAG?
发布评论