Воздушный поток: оператор имеет триггер по нескольким правилам триггера - PullRequest
Новая
       2

Воздушный поток: оператор имеет триггер по нескольким правилам триггера

1 голос
/ 21 января 2020

В настоящее время я пишу оператор следующим образом для запуска в конце моего графика 

fail = DummyOperator(
    task_id=t_fail,
    default_args=args,
    trigger_rule='one_failed',
    on_success_callback=partial(dag_complete_notification,
    dag_success=reference.DagCompleteStatus.INCOMPLETE),
    dag=dag
)

В идеале я бы вызвал оператор только тогда, когда все его восходящие потоки завершены, и если один из них не удалось.

Base_Operator, к сожалению, принимает только один аргумент для правила триггера, хотя я действительно хотел бы просто написать one_failed and all_complete.

Есть ли альтернативы для того, как подойти к этому?

...