如何停止气流DAG？

Question

使用python 2.7运行Airflow 1.9.0。如何正常停止DAG？

在这种情况下，我有一个DAG正在运行带有错误代码的文件上传，这会使所有内容花费4倍的时间，而且我真的不希望不必等待一天就可以最终超时（超时设置为10个小时）。

DAG查找tar文件。当找到一个文件时，它将遍历tar中的每个文件，寻找要处理的文件并进行处理。

我找不到停止DAG的任何方法。我尝试单击“ DAG运行”列中的“运行”圆圈（右侧的圆圈）。它让我选择该过程并将其标记为“失败”。但是它并没有停止运行。

我尝试单击“近期任务”列中的“正在运行”圆圈（左侧的一个）。它允许我选择流程，但是尝试将其设置为已归档（或成功），在Airflow中生成了异常

Answer 1

浏览 -> DAG 运行 -> 复选框 -> 选择“删除”

Answer 2

如果您按照听起来的方式构建流程，那么您将无法从 Airflow 中阻止它。您需要找到正在执行的进程标识符并强制终止它以使其真正停止。