diff --git a/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py b/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py index 6722eeda..0d8d606a 100644 --- 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 index 66afe05d..612b13d7 100644 --- 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 index e8a82f42..5efbba64 100644 --- 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 %}