重新触发具有upstream_failed状态的 DAG 的过去实例

Question

情况：具有depends_on_past=True的 DAG 配置为每天运行。现在，如果由于某种原因前一天的 DAG 失败，则当天的 DAG 任务将标记为状态"无"，并且不会触发。

要求：在这里，我们需要重新触发过去一天失败的任务，然后运行当天的 DAG。

关于我们如何实现这一目标的任何想法？

Answer 1

指定default_args时，您可以说明所需的重试次数。

例如：

default_args = {
'owner': 'ANDY',
'depends_on_past': True,
'start_date': datetime(2016, 1, 1),
'email': ['[e-mail]'],
'email_on_failure': True,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=1)}

只要您设置了正确的上游/下游依赖项，后续任务就会在最终完成后运行。我希望这有所帮助。