Variables que no están del todo bien
Tu jefa te pide investigar por qué no se está generando un informe de ventas. Hace poco implementaste variables en uno de tus Dags (process_sales), que procesa varios datos de ventas y guarda el informe del que te está hablando. Al revisar los registros, te das cuenta de que no está escribiendo en la ubicación prevista, sino en la predeterminada.
La tarea que procesa el informe hace lo siguiente:
@task()
def parse_file():
output_path = Variable.get("Output_Path", default="/home")
output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
save_file("{output_path}/{output_fn}")
El archivo debería guardarse como /data/sales/sales_report.pdf.
Prueba a ejecutar el comando airflow dags test process_sales para ver la salida del registro.
¿Cuál de las siguientes es la razón del error y cómo lo solucionarías?
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio