Introducción a Apache Airflow en Python
Mike Metzger
Data Engineer
Usando @task.branch
Ejecuta una función de Python que devuelve el id de la(s) próxima(s) tarea(s)
@task.branch
def branch_task(logical_date):
if int(logical_date.month) % 3 == 0:
# Months 3 - March, 6 - June, 9 - September, 12 - December
return 'end_of_quarter_task'
else:
# All other months
return 'regular_monthly_task'
@task.branch def branch_task(logical_date): if int(logical_date.month) % 3 == 0: # Months 3 - March, 6 - June, 9 - September, 12 - December return 'end_of_quarter_task' else: # All other months return 'regular_monthly_task'start_task >> branch_task >> end_of_quarter_task >> end_of_quarter_task2branch_task >> regular_monthly_task >> regular_monthly_task2



ds - Fecha lógica con guiones YYYY-MM-DDds_nodash - Fecha lógica sin guiones YYYYMMDDprev_data_interval_start_success - Fecha del último DAG correctoIntroducción a Apache Airflow en Python