Definire l'ordine di esecuzione della pipeline
Dopo aver costruito il tuo DAG, è il momento di definire l'ordine di esecuzione dei task del DAG.
Nel precedente esercizio hai configurato il primo task per controllare l'API. Tutti gli altri task della pipeline sono già pronti per te.
Devi seguire l'ordine dei task indicato nel diagramma qui sotto.
Questo esercizio fa parte del corso
Progettare pipeline di forecasting per la produzione
Istruzioni dell'esercizio
- Imposta i task della pipeline di controllo API e di verifica dello stato.
- Imposta i task della pipeline di validazione dei dati.
- Imposta i task della pipeline di previsione.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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")