Agende um Dag via Python
Você já aprendeu bastante sobre como criar Dags, mas agora quer agendar um Dag específico em um dia específico da semana, em um determinado horário. Você quer que o código inclua essas informações caso um colega precise reinstalar o Dag em outro servidor.
Os métodos apropriados de datetime e o objeto dag do Airflow já foram importados para você.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- Defina a data de início do Dag como 1º de novembro de 2025.
- Use a sintaxe de cron para configurar um agendamento para toda quarta-feira às 12h30.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()