Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[HOTFIX] corrige filtro incremental integracao_invalida e transacao_invalida #107

Merged
merged 31 commits into from
Jul 17, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
abd84eb
cria validação da jae com o gtfs
pixuimpou Jul 4, 2024
5fbb1c9
validacao ordem pagamento staging
pixuimpou Jul 9, 2024
07c2c62
Merge branch 'main' into staging/validacao-jae-gtfs
mergify[bot] Jul 9, 2024
b633b08
Merge branch 'main' into staging/validacao-jae-gtfs
mergify[bot] Jul 16, 2024
5bb25ba
adiciona operadoras de fretamento
pixuimpou Jul 17, 2024
0fa0abc
altera aux_servicos_gtfs para ephemeral
pixuimpou Jul 17, 2024
8340404
altera filtro incremental da integracao_invalida
pixuimpou Jul 17, 2024
90129cd
altera filtro incremental da transacao_invalida
pixuimpou Jul 17, 2024
e26988c
corrige aux_transacao_ordem
pixuimpou Jul 17, 2024
4ae7471
corrige validacao ordem_pagamento por servico
pixuimpou Jul 17, 2024
a9931f3
cria modelo ordem_pagamento_dia_invalida
pixuimpou Jul 17, 2024
a11c594
cria validacao ordem_pagamento final
pixuimpou Jul 17, 2024
d0f08cb
altera schema validacao_dados_jae
pixuimpou Jul 17, 2024
b94087b
agenda pipeline de materializacao das validacoes
pixuimpou Jul 17, 2024
3590a6d
corrige query viagem_informada
pixuimpou Jul 17, 2024
4e0e8d9
Merge branch 'staging/validacao-jae-gtfs' of https://github.com/prefe…
pixuimpou Jul 17, 2024
4da70b5
Merge branch 'main' into staging/validacao-jae-gtfs
mergify[bot] Jul 17, 2024
d6827a9
add changelog
pixuimpou Jul 17, 2024
7d2521a
adiciona prefixo data nas colunas de vigencia
pixuimpou Jul 17, 2024
9e7ff3d
corrige nome das colunas de vigencia
pixuimpou Jul 17, 2024
c4b2ac0
altera schema da tabela de servicos
pixuimpou Jul 17, 2024
3add40b
Merge branch 'staging/validacao-jae-gtfs' of https://github.com/prefe…
pixuimpou Jul 17, 2024
bb040e6
Merge branch 'main' into staging/validacao-jae-gtfs
mergify[bot] Jul 17, 2024
8bb98cd
add data dbt
pixuimpou Jul 17, 2024
abd30db
Merge branch 'staging/validacao-jae-gtfs' of https://github.com/prefe…
pixuimpou Jul 17, 2024
349ffe9
corrige typo
pixuimpou Jul 17, 2024
2546a98
altera cast para safe_cast
pixuimpou Jul 17, 2024
0e3a2bc
corrige filtro incremental
pixuimpou Jul 17, 2024
c93e315
Merge branch 'main' into staging/validacao-jae-gtfs
pixuimpou Jul 17, 2024
1442233
registra flows
pixuimpou Jul 17, 2024
42b9919
Merge branch 'staging/validacao-jae-gtfs' of https://github.com/prefe…
pixuimpou Jul 17, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
"""
Flows for br_rj_riodejaneiro_bilhetagem
DBT: 2024-07-17
DBT: 2024-07-17 2
"""

from copy import deepcopy
Expand Down
2 changes: 1 addition & 1 deletion queries/models/validacao_dados_jae/integracao_invalida.sql
Original file line number Diff line number Diff line change
Expand Up @@ -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 %}
Expand Down
2 changes: 1 addition & 1 deletion queries/models/validacao_dados_jae/transacao_invalida.sql
Original file line number Diff line number Diff line change
Expand Up @@ -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 %}
Expand Down
Loading