Variables pas tout à fait justes

Votre gestionnaire vous demande d'examiner un problème : un rapport des ventes n'est pas généré. Vous avez récemment mis en place des variables dans l'un de vos Dags (process_sales) qui traite des données de ventes diverses et écrit le rapport demandé. En consultant les journaux, vous réalisez que l'écriture ne se fait pas à l'emplacement prévu, mais à l'emplacement par défaut.

La tâche qui traite le rapport fait ceci :

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

Le fichier devrait être enregistré sous /data/sales/sales_report.pdf.

Essayez d'exécuter la commande airflow dags test process_sales pour voir la sortie des journaux.

Quelle est la raison de l'erreur et comment la corrigeriez-vous?