如何在气流 1.8 上出现故障时重新启动 dag?

问题描述

与:

default_args = {
    ...
    'retries': 1,
    'retry_delay': timedelta (seconds = 1),
    ...
}

多次重试失败的任务我可以得到，但是当一个任务失败，DAG再次启动时如何得到?

I can get the task that fails to retry several times, but how can I get it when a task fails, the DAG starts again?

当然，自动...

推荐答案

在 Airflow 中对此的规范解决方案是创建一个 subdagooperator，将所有其他任务包装在 dag 中，并对其应用重试.

The canonical solution to this in Airflow is to create a subdagoperator that wraps all the other tasks in the dag, and apply the retry to that.

这篇关于如何在气流 1.8 上出现故障时重新启动 dag?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！