【发布时间】：2023-03-09 14:50:01
【问题描述】：
正如标题所说，在我的运算符中，在它的 execute() 方法中，我想做类似的事情
if some_condition():
self.try_number = 0
因为我希望 Airflow 忘记之前的失败。我该怎么做？
【问题讨论】：
【发布时间】：2023-03-09 14:50:01
【问题描述】：
我不建议修改尝试次数，因为将来很难调试。但是如果你想尝试一下，为什么不访问task_instance对象并修改参数try_number或with_try_number呢？
我相信后者可以让您使用给定的尝试编号返回任务
【讨论】：
-
我决定在我的算子内部手动实现重试逻辑，必要时抛出 AirflowFailException。