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 exercicio faz parte do curso
Projetando Pipelines de Previsão para Produção
Instruções do exercicio
- 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.
exercicio interativo prático
Tente este exercicio 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")