Definir a ordem de BashOperators

Agora que você aprendeu sobre os operadores de bitshift, é hora de modificar seu workflow para incluir uma etapa de pull e definir a ordenação das tarefas. Você tem três componentes atualmente definidos: cleanup, consolidate e push_data.

O DAG analytics_dag está disponível como antes e o BashOperator já foi importado.

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Instruções do exercício

Defina um BashOperator chamado pull_sales com o comando bash wget https://salestracking/latestinfo?json.
Faça o operador pull_sales rodar antes da tarefa cleanup.
Configure consolidate para rodar em seguida, usando o operador downstream.
Defina push_data para rodar por último usando qualquer um dos operadores de bitshift.

Exercício interativo prático

Experimente este exercício completando este código de exemplo.

# Define a new pull_sales task
pull_sales = ____(
    task_id='pullsales_task',
    ____
)

# Set pull_sales to run prior to cleanup
pull_sales ____ cleanup

# Configure consolidate to run after cleanup
____

# Set push_data to run last
consolidate ____

Editar e executar o código