1. Nauka
    2. /
  2. Kursy
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

ćwiczenie

Wyzwalanie podrzędnego DAGa

Zauważasz, że niektóre z twoich przepływów pracy korzystają z podobnych komponentów i dochodzisz do wniosku, że wspólne zadania można wydzielić do osobnego DAGa. Dzięki temu będzie można uruchamiać te komponenty w razie potrzeby, bez konieczności utrzymywania wielu ich kopii. Postanawiasz wywołać podrzędny DAG jako zadanie w bieżącym przepływie pracy.

Komponenty dag, task i datetime zostały już zaimportowane.

Instrukcje

100 XP
  • Zaimportuj operator potrzebny do uruchomienia DAGa z poziomu bieżącego przepływu pracy.
  • Skonfiguruj operator tak, aby wyzwalał DAGa o nazwie child_pipeline.
  • Upewnij się, że nadrzędny DAG czeka na zakończenie wyzwolonego DAGa przed kontynuowaniem.
  • Ustaw, jak często operator sprawdza, czy podrzędny DAG zakończył działanie.