From e11fc2125f4fd6bf15a4a165a21e819f0fcd19b1 Mon Sep 17 00:00:00 2001 From: Guilherme Botelho Date: Wed, 7 Aug 2024 23:32:59 -0300 Subject: [PATCH] corrige refs --- pipelines/migration/br_rj_riodejaneiro_onibus_gps/flows.py | 2 +- .../sppo_aux_registros_filtrada.sql | 2 +- .../models/br_rj_riodejaneiro_veiculos/gps_sppo_15_minutos.sql | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pipelines/migration/br_rj_riodejaneiro_onibus_gps/flows.py b/pipelines/migration/br_rj_riodejaneiro_onibus_gps/flows.py index ed0e0258..5917961e 100644 --- a/pipelines/migration/br_rj_riodejaneiro_onibus_gps/flows.py +++ b/pipelines/migration/br_rj_riodejaneiro_onibus_gps/flows.py @@ -2,7 +2,7 @@ """ Flows for br_rj_riodejaneiro_onibus_gps -DBT 2024-08-07 +DBT: 2024-08-07 """ from copy import deepcopy diff --git a/queries/models/br_rj_riodejaneiro_onibus_gps/sppo_aux_registros_filtrada.sql b/queries/models/br_rj_riodejaneiro_onibus_gps/sppo_aux_registros_filtrada.sql index c12b981e..eabfdf4b 100644 --- a/queries/models/br_rj_riodejaneiro_onibus_gps/sppo_aux_registros_filtrada.sql +++ b/queries/models/br_rj_riodejaneiro_onibus_gps/sppo_aux_registros_filtrada.sql @@ -52,7 +52,7 @@ realocacao as ( FROM gps g LEFT JOIN - {{ ref('sppo_aux_registros_realocacao') ~ var('fifteen_minutes')}} r + {{ ref('sppo_aux_registros_realocacao' ~ var('fifteen_minutes')) }} r ON g.ordem = r.id_veiculo and g.timestamp_gps = r.timestamp_gps diff --git a/queries/models/br_rj_riodejaneiro_veiculos/gps_sppo_15_minutos.sql b/queries/models/br_rj_riodejaneiro_veiculos/gps_sppo_15_minutos.sql index 22143f37..c5e90ecf 100644 --- a/queries/models/br_rj_riodejaneiro_veiculos/gps_sppo_15_minutos.sql +++ b/queries/models/br_rj_riodejaneiro_veiculos/gps_sppo_15_minutos.sql @@ -35,7 +35,7 @@ WITH linha, latitude, longitude, - FROM {{ ref('sppo_aux_registros_filtrada') ~ var('fifteen_minutes') }} + FROM {{ ref('sppo_aux_registros_filtrada' ~ var('fifteen_minutes')) }} WHERE -- data between DATE("{{var('date_range_start')}}") and DATE("{{var('date_range_end')}}") -- AND timestamp_gps > "{{var('date_range_start')}}" and timestamp_gps <="{{var('date_range_end')}}"