python - 如何从 UI 停止/终止 Airflow 任务

Question

如何停止/终止 Airflow UI 上正在运行的任务？我正在使用 LocalExecutor。即使我使用 CeleryExecutor，我如何才能杀死/停止正在运行的任务？

Answer 1

在 DAG 屏幕中，您可以看到正在运行的任务:

Example

在“最近的任务”上按运行图标，Airflow 将自动运行搜索查询，其中 Dag Id 和状态的过滤器等于“正在运行”，并在“任务实例”屏幕上显示结果(您可以在选项卡浏览 > 任务实例)。

您可以在此处选择呈现的任务并将它们设置为另一种状态或删除它们。

请注意，如果 DAG 当前正在运行，Airflow 调度程序将重新启动您删除的任务。因此，要么通过更改状态先停止 DAG，要么停止调度程序(如果您在测试环境中运行)。