Airflow-Task-Lauf, egal was passiert mit Downstream

Question

Ich habe drei Aufgaben in einem Tag.

Aufgabe A zuerst ausgeführt. Task B wird ausgeführt, wenn Task A erfolgreich ist.

Ich habe Task C, die nach Task B ausgeführt wurde, aber es ist nicht abhängig von Task B oder Task A Erfolg oder Misserfolg.

Task C muss unabhängig davon, was mit Task A und B passiert. Es muss jedoch ausgeführt werden, nachdem Task A und B abgeschlossen ist.

Irgendeine Idee?

Answer 1

eine Aufgabe ausgeführt haben, nachdem andere Aufgaben erledigt werden, aber unabhängig vom Ergebnis ihrer Ausführung, stellen Sie die trigger_rule Parameter all_done wie so:

my_task = MyOperator(task_id='my_task', 
        trigger_rule='all_done' 

die trigger rule documentation für mehr Optionen anzeigen