Definindo a ordem de execução da pipeline
Depois de construir seu DAG, é hora de definir a ordem de execução das tarefas do DAG.
No exercício anterior, você configurou a primeira tarefa para verificar a API. Todas as outras tarefas da pipeline já estão configuradas para você.
Você precisa seguir a ordem das tarefas mostrada no diagrama abaixo.
Este exercício faz parte do curso
Projetando Pipelines de Previsão para Produção
Instruções do exercício
- Defina as tarefas de verificação da API e de verificação de status da pipeline.
- Defina as tarefas da pipeline de validação de dados.
- Defina as tarefas da pipeline de previsão.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# 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")