Merge branch 'main' into staging/radar-serpro

pipelines/migration/br_rj_riodejaneiro_gtfs/flows.py

@@ -2,7 +2,7 @@
 """
 Flows for gtfs
 
-DBT 2024-12-04a
+DBT 2024-12-20
 """
 
 from prefect import Parameter, case, task

pipelines/migration/projeto_subsidio_sppo/flows.py

@@ -3,7 +3,7 @@
 """
 Flows for projeto_subsidio_sppo
 
-DBT: 2024-12-18
+DBT: 2024-12-20
 """
 
 from prefect import Parameter, case, task

pipelines/treatment/monitoramento/flows.py

@@ -2,7 +2,7 @@
 """
 Flows de tratamento dos dados de monitoramento
 
-DBT: 2024-12-20
+DBT 2024-12-20
 """
 
 from copy import deepcopy

queries/models/dashboard_subsidio_sppo/schema.yml

@@ -241,6 +241,10 @@ models:
         description: "Quantidade de viagens apuradas realizadas por veículo licenciado com ar condicionado e registrado por agente de verão (RESOLUÇÃO SMTR Nº 3.682/2024) em razão de inoperância ou mau funcionamento deste."
       - name: km_apurada_registrado_com_ar_inoperante
         description: "Distância apurada de viagens realizadas por veículo licenciado com ar condicionado e registrado por agente de verão (RESOLUÇÃO SMTR Nº 3.682/2024) em razão de inoperância ou mau funcionamento deste (km)."
+      - name: viagens_sem_transacao
+        description: "Quantidade de viagens apuradas realizadas por veículo licenciado sem registros de transações RioCard."
+      - name: km_apurada_sem_transacao
+        description: "Distância apurada de viagens realizadas por veículo licenciado sem registros de transações RioCard."
   - name: valor_tipo_penalidade
     description: "Valores de penalidades de subsídio"
     columns:
@@ -628,9 +632,9 @@ models:
           - not_null:
               name: not_null__distancia_planejada__subsidio_km_teto
       - name: indicador_viagem_dentro_limite
-        description: "Indica se a viagem foi remunerada por estar abaixo do teto de 120%/200%."
+        description: "{{ doc('indicador_viagem_dentro_limite') }}"
         tests:
           - not_null:
               name: not_null__indicador_viagem_dentro_limite__viagens_remuneradas
-
-
+      - name: indicador_penalidade_judicial
+        description: "{{ doc('indicador_penalidade_judicial') }}"

queries/models/docs.md

@@ -334,4 +334,16 @@ Nome do trajeto.
 
 {% docs sentido %}
 Sentido da linha
+{% enddocs %}
+
+{% docs indicador_viagem_dentro_limite %}
+Indica se a viagem foi remunerada por estar abaixo do teto de 120%/200%.
+{% enddocs %}
+
+{% docs indicador_penalidade_judicial %}
+Indica que o valor encontra-se sob julgamento de ação judicial e será depositado em juízo.
+{% enddocs %}
+
+{% docs tipo_os %}
+Tipo de Ordem de Serviço (ex: 'Regular', 'Extraordinária - Verão')
 {% enddocs %}

queries/models/financeiro/schema.yaml

@@ -18,6 +18,10 @@ models:
         description: "Serviço realizado pelo veículo."
       - name: indicador_ar_condicionado
         description: "Indicador se o veículo foi licenciado com ar condicionado."
+      - name: indicador_penalidade_judicial
+        description: "{{ doc('indicador_penalidade_judicial') }}"
+      - name: indicador_viagem_dentro_limite
+        description: "{{ doc('indicador_viagem_dentro_limite') }}"
       - name: tipo_viagem
         description: "Tipo de viagem"
       - name: viagens_faixa
@@ -71,5 +75,22 @@ models:
         description: "Valor penalidade [negativa] (POF =< 60%)."
       - name: versao
         description: "{{ doc('versao') }}"
+      - name: datetime_ultima_atualizacao
+        description: "{{ doc('datetime_ultima_atualizacao') }}"
+  - name: subsidio_penalidade_servico_dia
+    description: "Tabela com o valor penalidade dos serviços de ônibus (SPPO) por dia e serviço."
+    columns:
+      - name: data
+        description: "{{ doc('data_gps') }}"
+      - name: tipo_dia
+        description: "{{ doc('tipo_dia') }}"
+      - name: consorcio
+        description: "{{ doc('consorcio') }}"
+      - name: servico
+        description: "{{ doc('servico') }}"
+      - name: valor_penalidade
+        description: "Valor penalidade [negativa] (POF =< 60%)."
+      - name: versao
+        description: "{{ doc('versao') }}"
       - name: datetime_ultima_atualizacao
         description: "{{ doc('datetime_ultima_atualizacao') }}"

queries/models/gtfs/schema.yml

@@ -67,7 +67,7 @@ models:
     columns:
       - name: service_id
         description: "Identifica um conjunto de datas quando ocorre uma exceção de serviço para uma ou mais rotas"
-      - name: date
+      - name: DATE
         description: "Data em que ocorre a exceção de serviço."
       - name: exception_type
         description: "Indica se o serviço está disponível na data especificada no campo de data."
@@ -546,6 +546,8 @@ models:
         description: "Nome do consórcio responsável pelo serviço."
       - name: sentido
         description: "Sentido planejado - categorias: I (ida), V (volta), C (circular)"
+      - name: partidas_total_planejada
+        description: "{{ doc('partidas') }}"
       - name: distancia_planejada
         description: "Distância planejada de uma viagem do serviço (km)."
       - name: distancia_total_planejada
@@ -554,6 +556,10 @@ models:
         description: "Horário inicial de funcionamento do serviço."
       - name: fim_periodo
         description: "Horário da final de funcionamento do serviço."
+      - name: faixa_horaria_inicio
+        description: "{{ doc('faixa_horaria_inicio') }}"
+      - name: faixa_horaria_fim
+        description: "{{ doc('faixa_horaria_fim') }}"
       - name: trip_id_planejado
         description: "Código identificador de trip de referência no GTFS"
       - name: trip_id

queries/models/monitoramento/schema.yml

@@ -141,6 +141,10 @@ models:
         description: Valor mínimo do indice_validacao para que a viagem seja validada.
         data_type: float64
         quote: true
+      - name: tipo_dia
+        description: "{{ doc('tipo_dia') }}"
+        data_type: string
+        quote: true
       - name: feed_version
         description: "{{ doc('feed_version') }}"
         data_type: string

queries/models/planejamento/schema.yml

@@ -242,11 +242,11 @@ models:
         data_type: string
         quote: true
       - name: subtipo_dia
-        description: "Subtipo de dia (ex: 'Verão')"
+        description: "Subtipo de dia (ex: 'Verão')."
         data_type: string
         quote: true
       - name: tipo_os
-        description: "Tipo de Ordem de Serviço (ex: 'Regular', 'Extraordinária - Verão')"
+        description: "{{ doc('tipo_os') }}"
         data_type: string
         quote: true
       - name: service_ids

queries/models/projeto_subsidio_sppo/schema.yml

@@ -218,6 +218,8 @@ models:
         identificação do trajeto)"
         tests:
           - not_null
+      - name: trip_id
+        description: "Código identificador do itinerário operado"
       - name: shape_id
         description: "Código identificador do shape (trajeto) do serviço"
         tests:
@@ -532,6 +534,8 @@ models:
         identificação do trajeto)"
         tests:
           - not_null
+      - name: trip_id
+        description: "Código identificador do itinerário operado"
       - name: shape_id
         description: "Código identificador do shape (trajeto) do serviço"
         tests:
@@ -582,6 +586,8 @@ models:
         tests:
           - not_null
           - greater_than_zero
+      - name: distancia_inicio_fim
+        description: "Soma da distância entre o ponto inicial do shape e o primeiro sinal de gps da viagem e a distância entre o ponto final do shape e o último sinal de gps da viagem (Km)"
       - name: n_registros_middle
         description: "Contagem de sinais de GPS emitidos no meio do
       trajeto."