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
<Kurs>Forecasting-Pipelines für die Produktion entwerfen</Kurs>Übungsanweisungen
- 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 praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# 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")