ok

Выключить его выключателем?

тогда шедулер будет игнорировать его вообще и не будет запускать upstream таски после выполненной

Здравствуйте, кто может пояснить что делают эти задачи в даге?

complex_dag_fun_1 = BashOperator(
   task_id='starter',
   bash_command='for i in {1..10}; do sleep 1 && echo "slept $i" E; done',
   dag=dag,
)

complex_dag_fun_2 = BashOperator(
   task_id='leaf_node1',
   bash_command='for i in {1..5}; do sleep 1 && echo "slept $i" E; done',
   dag=dag,
)

complex_dag_fun_3 = BashOperator(
   task_id='leaf_node_2',
   bash_command='for i in {1..10}; do sleep 1 && echo "slept $i" E; done',
   dag=dag,
)

complex_dag_fun_4 = BashOperator(
   task_id='bottleneck_node',
   bash_command='for i in {1..1}; do sleep 1 && echo "slept $i" E; done',
   dag=dag,
)

выполняют sleep в операционной системе

wait_for_downstream=True
depends_on_past=True

Ребят кидаю
raise AirflowSkipException

Но в даге выглядит вот так.

ЧЯДНТ?

SkipException => SKIPPED, что вы ждёте, если не это?)

Для меня странно, что в логах статус success

а после raise return есть?

Я думал, что success это успешно завершенная таска без ошибок.

А done завершенная таска

хотя не нужно по идее, выкинет исключение же

странно. у меня выкидывает просто skipped

Ну питон оператор ходит в функцию ввида:

Def start():
 Some code
 Try:
   Asser 1==1
 Except exception:
    Raise skip exetrion

 Return

Извиняюсь, с телефона пишу

Обманул. У меня вот такой код

Я делаю raise airflowskip exception в except части, но все равно не понимаю почему так в логах


Статус в таске правильный проставляется, и вроде бы работает не лезь.

Но хочется понятт

Это баг логирования https://github.com/apache/airflow/pull/14822

Кайф) а то я переживал, а стоило погуллить