为同一 dag 内的任务设置不同的重试延迟时间
Set different retry delay times for tasks within the same dag
我有一个包含许多子任务的 airflow dag，我知道当某些任务失败时，它们可以在 5 分钟内重新运行，而其他任务可以重新运行 在 60 分钟内。如何将我的任务设置为在失败时重新运行？
我在堆栈溢出时发现了这个 question and answer 但这只会改变重试次数。
运营商也应该支持 retry_delay - 请参阅 BaseOperator:
retry_delay (datetime.timedelta) – delay between retries
我有一个包含许多子任务的 airflow dag，我知道当某些任务失败时，它们可以在 5 分钟内重新运行，而其他任务可以重新运行 在 60 分钟内。如何将我的任务设置为在失败时重新运行？
我在堆栈溢出时发现了这个 question and answer 但这只会改变重试次数。
运营商也应该支持 retry_delay - 请参阅 BaseOperator:
retry_delay (datetime.timedelta) – delay between retries