airflow - 如何停止 Airflow DAG？

Question

使用 python 2.7 运行 Airflow 1.9.0。如何优雅地停止 DAG？

在这种情况下，我有一个 DAG 正在运行带有错误代码的文件上传，这导致一切都需要 4 倍的时间，而且我真的不想等待一天它终于超时(超时设置为10个小时)。

DAG 查找 tar 文件。当它找到一个时，它会遍历 tar 中的每个文件，寻找要处理的文件，然后处理它们。

我找不到任何方法来阻止 DAG。我尝试单击“DAG Runs”列(右侧的)中的“Running”圆圈。它让我选择进程并将其标记为“失败”。但它并没有停止运行。

我尝试单击“最近的任务”列(左侧的)中的“正在运行”圆圈。它让我选择进程，但试图将它们设置为已归档(或成功)，在 Airflow 中产生了异常

Answer 1

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