Comece agoraComece grátis

Variáveis não estão bem certas

Sua chefe pediu para você investigar um problema em que um relatório de vendas não está sendo gerado. Você adicionou recentemente variáveis em um dos seus Dags (process_sales), que processa alguns dados de vendas e grava o relatório solicitado. Ao analisar os logs, você percebe que o arquivo não está sendo gravado no local pretendido, e sim no padrão.

A tarefa que processa o relatório faz o seguinte:

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

O arquivo deveria ser armazenado como /data/sales/sales_report.pdf.

Tente executar o comando airflow dags test process_sales para ver a saída do log.

Qual das alternativas a seguir explica o motivo do erro e como você corrigiria?

Este exercicio faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

exercicio interativo prático

Transforme teoria em prática com um dos nossos exercicio interativos

Iniciar exercicio