Воздушный поток пропустить текущее задание

Question

Есть ли способ для Airflow пропустить текущую задачу из (Python) оператора? Например:

def execute():
    if condition:
        skip_current_task()

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

Пропуск последующих задач меня не устраивает (решение, предложенное в этом ответе: Как пропустить задачи в Airflow? ), аа также ветвление. Есть ли способ для задачи пометить свое состояние как skipped изнутри Оператора?

Answer 1

Разобрался! Пропустить задачу так же просто, как:

def execute():
    if condition:
        raise AirflowSkipException

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

Answer 2

Самое простое решение для пропуска задачи:

def execute():
    if condition:
        return

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

К сожалению, оно пометит задачу как DONE