Variabili non del tutto corrette

Il tuo capo ti chiede di indagare su un problema per cui un report delle vendite non viene generato. Hai appena implementato delle variabili in uno dei tuoi Dag (process_sales), che elabora alcuni dati di vendita e scrive il report di cui il capo sta chiedendo. Guardando i log, ti accorgi che non sta scrivendo nella posizione prevista, ma in quella predefinita.

Il task che elabora il report fa quanto segue:

@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}")

Il file dovrebbe essere salvato come /data/sales/sales_report.pdf.

Prova a eseguire il comando airflow dags test process_sales per visualizzare l'output del log.

Qual è il motivo dell'errore e come lo risolveresti?