변수 설정이 올바르지 않은 경우

상사로부터 판매 보고서가 생성되지 않는 문제를 조사해 달라는 요청을 받았습니다. 최근에 DAG(process_sales) 중 하나에 변수를 추가했는데, 이 DAG는 다양한 판매 데이터를 처리하고 상사가 요청한 보고서를 출력합니다. 로그를 확인해 보니 파일이 의도한 위치가 아닌 기본 위치에 저장되고 있음을 발견했습니다.

보고서를 처리하는 태스크는 다음과 같습니다.

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

파일은 /data/sales/sales_report.pdf로 저장되어야 합니다.

airflow dags test process_sales 명령을 실행하여 로그 출력을 확인해 보세요.

오류의 원인과 해결 방법으로 올바른 것은 무엇인가요?