Ausführungsreihenfolge der Pipeline festlegen
Nachdem du deinen DAG erstellt hast, ist es an der Zeit, die Ausführungsreihenfolge der Tasks im DAG festzulegen.
In der vorherigen Übung hast du die erste Task zum Prüfen der API eingerichtet. Alle anderen Tasks der Pipeline sind bereits für dich vorbereitet.
Du musst der Reihenfolge der Tasks aus dem folgenden Diagramm folgen.
Diese Übung ist Teil des Kurses
Forecasting-Pipelines für die Produktion entwerfen
Anleitung zur Übung
- Richte die Tasks für die API-Check-Pipeline und den Status-Check ein.
- Richte die Tasks für die Datenvalidierungs-Pipeline ein.
- Richte die Tasks für die Forecast-Pipeline ein.
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")