diff --git a/pipelines/ocr_radar/dump_db_radar/flows.py b/pipelines/ocr_radar/dump_db_radar/flows.py index 927976f..3ae8f58 100644 --- a/pipelines/ocr_radar/dump_db_radar/flows.py +++ b/pipelines/ocr_radar/dump_db_radar/flows.py @@ -1,6 +1,6 @@ # -*- coding: utf-8 -*- """ -Database dumping flows for cetrio project . +Database dumping flows for cetrio project . """ from copy import deepcopy diff --git a/pipelines/templates/run_dbt_model/flows.py b/pipelines/templates/run_dbt_model/flows.py index 92a83de..129cf73 100644 --- a/pipelines/templates/run_dbt_model/flows.py +++ b/pipelines/templates/run_dbt_model/flows.py @@ -1,6 +1,6 @@ # -*- coding: utf-8 -*- """ -MATERIALIZA MODELOS DO DBT . +MATERIALIZA MODELOS DO DBT . """ from copy import deepcopy diff --git a/queries/models/ocr_radar/equipamento.sql b/queries/models/ocr_radar/equipamento.sql index f132c02..c034e78 100644 --- a/queries/models/ocr_radar/equipamento.sql +++ b/queries/models/ocr_radar/equipamento.sql @@ -7,5 +7,5 @@ SELECT CAST(longitude AS FLOAT64) as longitude, CAST(logradouro AS STRING) as logradouro, CAST(sentido AS STRING) as sentido, - CAST(sentido AS INT64) as velofisc + CAST(REGEXP_REPLACE(velofisc, r'\.0$', '') AS INT64) as velofisc FROM `rj-cetrio.ocr_radar_staging.equipamento` \ No newline at end of file