如果之前的任务失败，如何停止我的依赖任务

Question

嗨，我想设置气流作业计划...我有 3 个任务，即task_1>tast_2> task_3。

If first task , task_1 fails I need to stop remaining tasks being executed.
How this can be handled ?
How can I know earlier job failed or succeeded ? how to get task status ?

Answer 1

请参考下面的示例代码：

from airflow import DAG
from airflow.operators.python_operator import PythonOperator, BranchPythonOperator
from airflow.utils.trigger_rule import TriggerRule
import datetime as dt
args = {
'owner': 'airflow',
'start_date': '2020-06-02'
}
dag = DAG(
'testing_trigger_rule',
schedule_interval="@daily",
default_args=args
)
def task1():
print('Running task1')
def task2():
print('Running task2')
def task3():
print('Running task3')
Task1 = PythonOperator(
task_id='task1',
python_callable=task1,
trigger_rule=TriggerRule.ALL_SUCCESS,
dag=dag
)
Task2 = PythonOperator(
task_id='task2',
python_callable=task2,
trigger_rule=TriggerRule.ALL_SUCCESS,
dag=dag
)
Task3 = PythonOperator(
task_id='task3',
python_callable=task3,
trigger_rule=TriggerRule.ALL_SUCCESS,
dag=dag
)
Task1 >> Task2 >> Task3

有关触发规则的更多信息，请查看此链接。