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

Connected

ćwiczenie

Definiowanie kolejności zadań

Skoro już wiesz, jak działa składnia bitshift, czas zdefiniować kolejność wykonywania zadań. Masz do dyspozycji trzy zdefiniowane zadania: cleanup, consolidate oraz push_data.

Dekoratory dag i task z biblioteki airflow.sdk są już zaimportowane.

Instrukcje

100 XP
  • Skonfiguruj zadanie cleanup tak, aby uruchamiało się przed zadaniem consolidate, używając składni bitshift.
  • Skonfiguruj consolidate jako kolejne zadanie, a push_data jako ostatnie.