1
resposta

Erro no parâmetro de data do Airflow (notebook_params)

Aparantemente, meu código está todo correto, mas estou com erro no "notebook_params", acredito que a variável não está sendo reconhecida.

Se eu passo a data na função manualmente, funciona: Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Mas se eu utilizo da mesma forma que está sendo feita na aula, a variavel "data_execucao" não funciona. Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Por que isso está acontecendo? Já tentei debugar pelo chat gpt, usar outros códigos além desse 'data_interval_end', mas nada funciona.

Agradeço a ajuda.

1 resposta

Oii, Antonio! Como você está?

No seu código notebook_params, possui um espaço extra na expressão e entre as pas duplas e simples. Isso pode causar um erro, pois a leitura do código pode ser sensível e detecntar esses pequenos detalhes.

Como sugestão para solucionar é retirar esse espaço, deixando o código assim:

extraindo_dados = DatabricksRunNowOperator(
    task_id='Extraindo-conversoes',
    databricks_conn_id='databricks_default',
    job_id=110228395217462,
    notebook_params={"data_execucao": '{{ data_interval_end.strftime("%Y-%m-%d") }}'}  #retirando o espaço aqui, antes de data_interval_end
)

Atualize e observe se o código funciona como esperado. Espero que dê certinho!

Bons estudos, Antonio!