restart - 如何在 Airflow 1.8 上出现故障时重新启动 dag？

Question

和:

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

多次重试都可以获取失败的任务，但是当一个任务失败，DAG再次启动时如何获取呢？

当然，自动...

Answer 1

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