Des variables pas tout à fait correctes

Votre manager 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 diverses données de ventes et écrit le rapport demandé. En consultant les journaux, vous réalisez que le fichier n’est pas écrit à l’emplacement prévu, mais à l’emplacement par défaut.

La tâche qui génère 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 afficher la sortie des journaux.

Quelle est la cause de l’erreur parmi les propositions suivantes, et comment la corrigeriez-vous ?