在气流 1.8 上失败时如何重新启动 dag？

Question

和：

\n\n

default_args = {\n    ...\n\xc2\xa0\xc2\xa0\xc2\xa0 'retries': 1,\n    'retry_delay': timedelta (seconds = 1),\n    ...\n} \n

\n\n

我可以获取重试多次失败的任务，但是当任务失败，DAG重新启动时如何获取？

\n\n

当然，自动...

\n

Answer 1

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