Reihenfolge der Tasks festlegen

Nachdem du die Bitshift-Syntax kennengelernt hast, ist es Zeit, die Task-Reihenfolge festzulegen. Du hast derzeit drei definierte Tasks: cleanup, consolidate und push_data.

Die dag- und task-Dekoratoren aus airflow.sdk sind bereits importiert.

Diese Übung ist Teil des Kurses

<Kurs>Einführung in Apache Airflow mit Python</Kurs>

Kurs ansehen

Übungsanweisungen

Konfiguriere den Task cleanup so, dass er mit der Bitshift-Syntax vor dem Task consolidate ausgeführt wird.
Konfiguriere consolidate als nächsten Schritt und push_data als letzten Task.

Interaktive praktische Übung

Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.

@dag(
    dag_id="analytics_dag",
    start_date=datetime(2026, 3, 1),
)
def analytics_dag():
    # Run cleanup before consolidate
    cleanup() ____ consolidate()
    # Run consolidate before push_data
    ____

analytics_dag()

Code bearbeiten und ausführen