Definir a ordem das tarefas
Agora que você aprendeu sobre a sintaxe de bitshift, é hora de definir a ordem das tarefas. Você tem três tarefas definidas atualmente: cleanup, consolidate e push_data.
Os decoradores dag e task de airflow.sdk já foram importados.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- Configure a tarefa
cleanuppara rodar primeiro, antes da tarefaconsolidate, usando a sintaxe de bitshift. - Configure
consolidatepara rodar em seguida e a tarefapush_datapara rodar por último.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()