From fa8320b516ffa45abb6d2da02c8ab2f4399f3133 Mon Sep 17 00:00:00 2001 From: vtr363 Date: Mon, 19 Aug 2024 16:51:39 -0300 Subject: [PATCH] =?UTF-8?q?corre=C3=A7=C3=A3o=20na=20query=20teste=5Fsubsi?= =?UTF-8?q?do=5Fviagens=5Fatualizadas?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../migration/projeto_subsidio_sppo/constants.py | 12 ++++++------ pipelines/migration/projeto_subsidio_sppo/flows.py | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/pipelines/migration/projeto_subsidio_sppo/constants.py b/pipelines/migration/projeto_subsidio_sppo/constants.py index 9f34c127..e1fe3ef9 100644 --- a/pipelines/migration/projeto_subsidio_sppo/constants.py +++ b/pipelines/migration/projeto_subsidio_sppo/constants.py @@ -503,8 +503,8 @@ class constants(Enum): # pylint: disable=c0103 -- `rj-smtr.dashboard_subsidio_sppo.sumario_servico_dia_historico` `rj-smtr-dev.dashboard_subsidio_sppo_novos_teste_subsidio.sumario_servico_dia_historico` WHERE - DATA BETWEEN "{start_timestamp}" - AND "{end_timestamp}" ) + DATA BETWEEN DATE("{start_timestamp}") + AND DATE("{end_timestamp}") SELECT DISTINCT DATA FROM @@ -543,9 +543,6 @@ class constants(Enum): # pylint: disable=c0103 "Todos os dados de status dos veículos foram devidamente tratados": { "test": "check_sppo_veiculo_dia", }, - "Todas as viagens foram processadas com feed atualizado do GTFS": { - "test": "check_viagem_completa", - }, } } SUBSIDIO_SPPO_DATA_CHECKS_POS_LIST = { @@ -698,8 +695,11 @@ class constants(Enum): # pylint: disable=c0103 "Todas viagens com valor de subsídio por km não nulo e maior ou igual a zero": { "expression": "subsidio_km IS NOT NULL AND subsidio_km >= 0", }, - "Todas as viagens foram atualizadas antes do processamento do subsídio": { + "Todas viagens atualizadas antes do processamento do subsídio": { "test": "teste_subsido_viagens_atualizadas" }, + "Todas viagens processadas com feed atualizado do GTFS": { + "test": "check_viagem_completa", + }, }, } diff --git a/pipelines/migration/projeto_subsidio_sppo/flows.py b/pipelines/migration/projeto_subsidio_sppo/flows.py index 59c21ee0..06849cac 100644 --- a/pipelines/migration/projeto_subsidio_sppo/flows.py +++ b/pipelines/migration/projeto_subsidio_sppo/flows.py @@ -3,7 +3,7 @@ """ Flows for projeto_subsidio_sppo -DBT 2024-08-19 +DBT 2024-08-19 """ from prefect import Parameter, case, task