HOTFIX - Corrige referências na aux_passageiros_hora

pipelines/migration/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog - br_rj_riodejaneiro_bilhetagem
 
+## [1.4.0] - 2024-08-26
+
+### Alterado
+
+- Separa materialização da `passageiros_hora` da `transacao` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)
+
 ## [1.3.1] - 2024-08-19
 
 ### Alterado

pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py

@@ -2,7 +2,7 @@
 """
 Flows for br_rj_riodejaneiro_bilhetagem
 
-DBT: 2024-08-21 2
+DBT: 2024-08-26
 """
 
 from copy import deepcopy

pipelines/migration/br_rj_riodejaneiro_onibus_gps_zirix/CHANGELOG.md

@@ -0,0 +1,6 @@
+# Changelog - br_rj_riodejaneiro_onibus_gps_zirix
+
+## [1.0.0] - 2024-08-26
+
+### Corrigido
+- Corrige table_id na task `get_materialization_date_range` no flow `materialize_sppo_zirix` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)

pipelines/migration/br_rj_riodejaneiro_onibus_gps_zirix/flows.py

@@ -2,7 +2,7 @@
 """
 Flows for br_rj_riodejaneiro_onibus_gps_zirix
 
-DBT 2024-08-20
+DBT 2024-08-26
 """
 from prefect import Parameter, case
 from prefect.run_configs import KubernetesRun

queries/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md

@@ -1,5 +1,21 @@
 # Changelog - bilhetagem
 
+## [2.3.0] - 2024-08-26
+
+### Adicionado
+- Cria modelos `staging_linha_consorcio_operadora_transporte.sql` e `staging_endereco.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)
+
+### Alterado
+- Utiliza data e hora no filtro incremental dos modelos (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164):
+  - `transacao.sql`
+  - `transacao_riocard.sql`
+  - `passageiros_hora.sql`
+  - `passageiros_tile_hora.sql`
+- Adiciona coluna geo_point_transacao nos modelos `transacao.sql` e `transacao_riocard.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)
+- Altera materialized do modelo `aux_passageiros_hora.sql` de `table` para `ephemeral` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)
+- Adiciona transações do RioCard no modelo `aux_passageiros_hora.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/164)
+
+
 ## [2.2.1] - 2024-08-09
 
 ### Adicionado

queries/models/br_rj_riodejaneiro_bilhetagem_staging/aux_passageiros_hora.sql

@@ -23,7 +23,7 @@ SELECT
   tipo_pagamento,
   geo_point_transacao
 FROM
-  {{ transacao_table }}
+  {{ ref('transacao') }}
 WHERE
   id_servico_jae NOT IN ("140", "142")
   AND id_operadora != "2"
@@ -54,7 +54,7 @@ SELECT
   "RioCard" AS tipo_pagamento,
   ST_GEOGPOINT(longitude, latitude) AS geo_point_transacao
 FROM
-  {{ transacao_riocard_table }}
+  {{ ref('transacao_riocard') }}
 WHERE
   (id_servico_jae NOT IN ("140", "142") OR id_servico_jae IS NULL)
   AND (id_operadora != "2" OR id_operadora IS NULL)