[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
4条答案
按热度按时间y3bcpkx11#
只需将任务设置为失败状态,即可停止正在运行的任务。
k75qkfdt2#
在dags屏幕中,您可以看到正在运行的任务:
例子
在“最近的任务”上,按running图标,airflow将自动运行搜索查询,其中dag id和状态的筛选器等于“running”,并在task instances屏幕上显示结果(您可以在browse>task instances选项卡上手动查找)。
在那里,您可以选择呈现的任务,并将它们设置为其他状态或删除它们。
请注意,如果dag当前正在运行,气流调度器将再次启动您删除的任务。因此,要么先通过更改dag的状态来停止dag,要么停止调度程序(如果在测试环境中运行)。
qv7cva1a3#
正如pablo和jorge所说,如果任务已经开始执行,暂停dag不会停止任务的执行。不过,有一种方法可以从ui中停止正在运行的任务,但它有点不成熟。
当任务启动时
running
说明你可以点击CLEAR
这将呼叫job.kill()
任务将设置为shut_down
然后搬到up_for_retry
因此立即停止。很明显,气流并不意味着你要清理工作
Running
然而,由于气流没有禁用它,你也可以使用它作为我的建议。气流意味着CLEAR
与…一起使用failed
,up_for_retry
等。。。也许将来社区会使用这个bug(?)并通过“shutdowntask”按钮实现这个功能。deikduxw4#
来自气流gitter(@villasv)
不,不。你可以停止一个dag(取消标记为正在运行),清除任务状态,甚至在ui中删除它们。执行器中实际运行的任务不会停止,但如果执行器意识到它不再在数据库中,则可能会被终止。“