根据官方的Airflow文档,需要处于成功状态的task instances直接上游task。另外,如果您设置了depends_on_past = True,则前一个任务实例需要成功(除非它是该任务的第一次运行)。
众所周知,任务是一种“实例化和参数化”的运算符。
现在,这让我感到困惑。例如:
DAG: {op_1} -> {op_2} -> {op_3}
Run Code Online (Sandbox Code Playgroud)
{op_2}是一个简单的PythonOperator,它从{op_1}获取1个参数并执行操作;
据我了解,op_2(param_1)和op_2(param_2)被视为2个不同的任务。
Given depends_on_past设置为True,则: