如何在 Airflow 运算符中跳过任务？答案

【问题标题】：How to skip task in Airflow operator?如何在 Airflow 运算符中跳过任务？
【发布时间】：2019-10-16 13:19:17
【问题描述】：

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

def execute():
    if condition:
        skip_current_task()

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

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

【问题讨论】：

【解决方案1】：

想通了！跳过任务很简单：

def execute():
    if condition:
        raise AirflowSkipException

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

【讨论】：

【解决方案2】：

跳过任务的最简单解决方案：

def execute():
    if condition:
        return

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

不幸的是，它会将任务标记为DONE

【讨论】：