From 4dde4ca4ed49cae335d935c3866d61b3983d132a Mon Sep 17 00:00:00 2001 From: Rafael Carvalho Pinheiro <74972217+pixuimpou@users.noreply.github.com> Date: Fri, 20 Dec 2024 10:42:02 -0300 Subject: [PATCH] [HOTFIX] Corrige variavel flow do datario (#367) * altera local da task log_discord * cria flow de verificacao de conexao com a jae * move task log_discord * cria funcao para testar conexao com banco de dados * remove prefixo do filtro de flows * flow config * ajusta mensagem do discord * desativa materializacao viagem_planejada_planejamento * add changelog * link pr * trata dados nulos * corrige variavel datario --------- Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com> --- pipelines/treatment/datario/flows.py | 2 +- pipelines/treatment/monitoramento/flows.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pipelines/treatment/datario/flows.py b/pipelines/treatment/datario/flows.py index 219fa671..c23da9e1 100644 --- a/pipelines/treatment/datario/flows.py +++ b/pipelines/treatment/datario/flows.py @@ -8,7 +8,7 @@ from pipelines.treatment.datario.constants import constants from pipelines.treatment.templates.flows import create_default_materialization_flow -VIAGEM_INFORMADA_MATERIALIZACAO = create_default_materialization_flow( +DATARIO_MATERIALIZACAO = create_default_materialization_flow( flow_name="datario - materializacao", selector=constants.DATARIO_SELECTOR.value, agent_label=smtr_constants.RJ_SMTR_AGENT_LABEL.value, diff --git a/pipelines/treatment/monitoramento/flows.py b/pipelines/treatment/monitoramento/flows.py index 32665187..14481f73 100644 --- a/pipelines/treatment/monitoramento/flows.py +++ b/pipelines/treatment/monitoramento/flows.py @@ -2,7 +2,7 @@ """ Flows de tratamento dos dados de monitoramento -DBT: 2024-11-21 +DBT: 2024-12-20 """ from copy import deepcopy