According to the official Airflow docs,
The task instances
directly upstream from the task
need to be in a success state. Also, if you have set depends_on_past=True, the previous task instance needs to have succeeded (except if it is the first run for that task).
As all know, the task is kind of 'instantiated & parameteriazed' operator.
Now this is what confuse me. For example:
DAG: {op_1} -> {op_2} -> {op_3}
{op_2} is a simple PythonOperator that takes 1 parameter from {op_1} and do stuff;
To my understanding, op_2(param_1) & op_2(param_2) are considered as 2 different tasks.
Given depends_on_past
is set to True, then:
- If op_2(param_1) is still running; can op_2(param_2) be run?
- If op_2(param_1) fails in the previous run; can op_2(param_1) be run in the current run?
See Question&Answers more detail:
os 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…