Programa un Dag desde Python
Has aprendido bastante sobre cómo crear Dags, pero ahora quieres programar un Dag concreto en un día específico de la semana a una hora determinada. Quieres que el código incluya esta información por si un/a colega necesita reinstalar el Dag en otro servidor.
Ya se han importado por ti el objeto dag de Airflow y los métodos adecuados de datetime.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Establece la fecha de inicio del Dag al 1 de noviembre de 2025.
- Usa la sintaxis de cron para configurar una programación de todos los miércoles a las 12:30 p. m.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
@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()