和:
default_args = {
...
'retries': 1,
'retry_delay': timedelta (seconds = 1),
...
}
多次重试都可以获取失败的任务,但是当一个任务失败,DAG再次启动时如何获取呢?
当然,自动...
最佳答案
在 Airflow 中对此的规范解决方案是创建一个 subdagooperator,它将所有其他任务包装在 dag 中,并对其应用重试。
关于restart - 如何在 Airflow 1.8 上出现故障时重新启动 dag?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50796596/