在 Airflow 中手动设置任务的尝试次数

Manually setting task's try number in Airflow

正如标题所说，在我的运算符中，在它的 execute() 方法中，我想做一些类似的事情

if some_condition():
  self.try_number = 0

因为我想让Airflow忘记之前的失败。我该怎么做？

我不建议修改尝试号，因为以后很难调试。但是，如果您想尝试一下，为什么不访问 task_instance 对象并修改参数 try_number 或 with_try_number?

我相信后者可以让你return你的任务具有给定的尝试次数