EmpezarEmpieza gratis

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

Ver curso

ejercicio interactivo práctico

Convierte la teoría en práctica con uno de nuestros ejercicios interactivos

Empezar ejercicio