当任务排队且未恢复时,它们会在 Airflow 中移至已删除状态

Swa*_*ale 7 airflow

当任务实例在 Airflow 中标记为 State.REMOVED 状态时?当我使用 for 循环动态生成任务时,执行其中一项任务后,其他任务将被删除并且不会再次恢复。

joe*_*oeb 5

当该方法在数据库中发现关联对象上不再存在的状态时,该方法REMOVED将应用该状态。如果您动态构建具有不同值的任务,这种情况肯定会发生。airflow.models.DagRun:verify_integritytask_idDAGtask_id

  • @SwapnilDengale,我们也面临同样的问题,您对此有何解决办法。 (4认同)