气流depends_on_past说明

Question

根据官方的Airflow文档，需要处于成功状态的task instances直接上游task。另外，如果您设置了depends_on_past = True，则前一个任务实例需要成功（除非它是该任务的第一次运行）。

众所周知，任务是一种“实例化和参数化”的运算符。

现在，这让我感到困惑。例如：

DAG: {op_1} -> {op_2} -> {op_3}

{op_2}是一个简单的PythonOperator，它从{op_1}获取1个参数并执行操作；

据我了解，op_2（param_1）和op_2（param_2）被视为2个不同的任务。

Given depends_on_past设置为True，则：

1. 如果op_2（param_1）仍在运行；可以运行op_2（param_2）吗？
2. 如果op_2（param_1）在上一次运行中失败；可以在当前运行中运行op_2（param_1）吗？

Answer 1

从官方文档中获取触发规则：

depends_on_past （布尔值）设置为True时，如果先前的任务计划未成功执行，则不会触发任务。

因此，除非您的DAG的先前运行失败，depends_on_past否则这不是一个因素，如果先前的运行成功执行了任务，它将完全不会影响当前的运行。