Variablen nicht ganz korrekt

Dein Chef bittet dich, ein Problem zu untersuchen, bei dem ein Verkaufsbericht nicht generiert wird. Du hast kürzlich in einem deiner Dags (process_sales) Variablen implementiert, der einige Verkaufsdaten verarbeitet und den Bericht schreibt, nach dem dein Chef fragt. Beim Blick in die Logs stellst du fest, dass nicht an den vorgesehenen Ort geschrieben wird, sondern an den Standardpfad.

Die Aufgabe, die den Bericht verarbeitet, macht Folgendes:

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

Die Datei sollte als /data/sales/sales_report.pdf gespeichert werden.

Führe den Befehl airflow dags test process_sales aus, um die Log-Ausgaben anzusehen.

Was ist der Grund für den Fehler, und wie würdest du ihn beheben?