如何跳过气流操作员中的任务？

Question

Airflow 有没有办法从 PythonOperator 跳过当前任务？例如：

def execute():
    if condition:
        skip_current_task()

task = PythonOperator(task_id='task', python_callable=execute, dag=some_dag)

并且还在 Airflow UI 中将任务标记为“已跳过”？

Answer 1

弄清楚了！跳过任务很简单：

def execute():
    if condition:
        raise AirflowSkipException

task = PythonOperator(task_id='task', python_callable=execute, dag=some_dag)