如何从ui停止/终止任务

hec6srdp  于 2021-05-29  发布在  Hadoop
关注(0)|答案(4)|浏览(686)

如何在ui上停止/终止正在运行的任务?我正在使用 LocalExecutor . 即使我使用 CeleryExecutor ,如何终止/停止正在运行的任务?

y3bcpkx1

y3bcpkx11#

只需将任务设置为失败状态,即可停止正在运行的任务。

[2019-09-17 23:53:28,040] {logging_mixin.py:82} INFO - [2019-09-17 23:53:28,039] {jobs.py:2695} WARNING - State of this instance has been externally set to failed. Taking the poison pill.
[2019-09-17 23:53:28,041] {helpers.py:240} INFO - Sending Signals.SIGTERM to GPID 20977
k75qkfdt

k75qkfdt2#

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

例子
在“最近的任务”上,按running图标,airflow将自动运行搜索查询,其中dag id和状态的筛选器等于“running”,并在task instances屏幕上显示结果(您可以在browse>task instances选项卡上手动查找)。
在那里,您可以选择呈现的任务,并将它们设置为其他状态或删除它们。
请注意,如果dag当前正在运行,气流调度器将再次启动您删除的任务。因此,要么先通过更改dag的状态来停止dag,要么停止调度程序(如果在测试环境中运行)。

qv7cva1a

qv7cva1a3#

正如pablo和jorge所说,如果任务已经开始执行,暂停dag不会停止任务的执行。不过,有一种方法可以从ui中停止正在运行的任务,但它有点不成熟。
当任务启动时 running 说明你可以点击 CLEAR 这将呼叫 job.kill() 任务将设置为 shut_down 然后搬到 up_for_retry 因此立即停止。
很明显,气流并不意味着你要清理工作 Running 然而,由于气流没有禁用它,你也可以使用它作为我的建议。气流意味着 CLEAR 与…一起使用 failed , up_for_retry 等。。。也许将来社区会使用这个bug(?)并通过“shutdowntask”按钮实现这个功能。

deikduxw

deikduxw4#

来自气流gitter(@villasv)
不,不。你可以停止一个dag(取消标记为正在运行),清除任务状态,甚至在ui中删除它们。执行器中实际运行的任务不会停止,但如果执行器意识到它不再在数据库中,则可能会被终止。“

相关问题