[HOTFIX] corrige filtro incremental integracao_invalida e `transaca…

…o_invalida` (#107) * cria validação da jae com o gtfs * validacao ordem pagamento staging * adiciona operadoras de fretamento * altera aux_servicos_gtfs para ephemeral * altera filtro incremental da integracao_invalida * altera filtro incremental da transacao_invalida * corrige aux_transacao_ordem * corrige validacao ordem_pagamento por servico * cria modelo ordem_pagamento_dia_invalida * cria validacao ordem_pagamento final * altera schema validacao_dados_jae * agenda pipeline de materializacao das validacoes * corrige query viagem_informada * add changelog * adiciona prefixo data nas colunas de vigencia * corrige nome das colunas de vigencia * altera schema da tabela de servicos * add data dbt * corrige typo * altera cast para safe_cast * corrige filtro incremental * registra flows --------- Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
prefeitura-rio · Jul 17, 2024 · b8a6119 · b8a6119
1 parent 490badc
commit b8a6119
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py b/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py
@@ -2,7 +2,7 @@
 """
 Flows for br_rj_riodejaneiro_bilhetagem
 
-DBT: 2024-07-17
+DBT: 2024-07-17 2
 """
 
 from copy import deepcopy

diff --git a/queries/models/validacao_dados_jae/integracao_invalida.sql b/queries/models/validacao_dados_jae/integracao_invalida.sql
@@ -51,8 +51,8 @@ integracao_agg AS (
     MIN(intervalo_integracao) AS menor_intervalo
   FROM
     {{ ref("integracao") }}
-  WHERE
     {% if is_incremental() %}
+      WHERE
       {% if partition_list|length > 0 %}
         data IN ({{ partition_list|join(', ') }})
       {% else %}

diff --git a/queries/models/validacao_dados_jae/transacao_invalida.sql b/queries/models/validacao_dados_jae/transacao_invalida.sql
@@ -62,8 +62,8 @@ WITH transacao AS (
   ON
     t.id_servico_jae = s.id_servico_jae
     AND t.data >= s.data_inicio_vigencia AND (t.data <= s.data_fim_vigencia OR s.data_fim_vigencia IS NULL)
-  WHERE
     {% if is_incremental() %}
+      WHERE
       {% if partition_list|length > 0 %}
         data IN ({{ partition_list|join(', ') }})
       {% else %}