From a73bd31d1b1b4b1dd1f2a53bc0e191a9ba0592a7 Mon Sep 17 00:00:00 2001 From: folhesgabriel Date: Mon, 16 Dec 2024 12:22:03 -0300 Subject: [PATCH] feat: update models --- .../br_me_caged__microdados_movimentacao_excluida.sql | 5 ++++- .../br_me_caged__microdados_movimentacao_fora_prazo.sql | 6 +++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/models/br_me_caged/br_me_caged__microdados_movimentacao_excluida.sql b/models/br_me_caged/br_me_caged__microdados_movimentacao_excluida.sql index a20fcb51..98b964ec 100644 --- a/models/br_me_caged/br_me_caged__microdados_movimentacao_excluida.sql +++ b/models/br_me_caged/br_me_caged__microdados_movimentacao_excluida.sql @@ -7,9 +7,12 @@ pre_hook="DROP ALL ROW ACCESS POLICIES ON {{ this }}", ) }} + select safe_cast(ano as int64) ano, safe_cast(mes as int64) mes, + safe_cast(SUBSTRING(competenciamov, 1, 4) as int64) ano_competencia_movimentacao, + safe_cast(SUBSTRING(competenciamov, 5, 6) as int64) mes_competencia_movimentacao, safe_cast(a.sigla_uf as string) sigla_uf, safe_cast(b.id_municipio as string) id_municipio, safe_cast(cnae_2_secao as string) cnae_2_secao, @@ -44,5 +47,5 @@ select safe_cast(indicador_fora_prazo as int64) indicador_fora_prazo from `basedosdados-dev.br_me_caged_staging.microdados_movimentacao_excluida` a left join - `basedosdados-dev.br_bd_diretorios_brasil.municipio` b + `basedosdados.br_bd_diretorios_brasil.municipio` b on a.id_municipio = b.id_municipio_6 diff --git a/models/br_me_caged/br_me_caged__microdados_movimentacao_fora_prazo.sql b/models/br_me_caged/br_me_caged__microdados_movimentacao_fora_prazo.sql index fa8dcce6..27af8cf9 100644 --- a/models/br_me_caged/br_me_caged__microdados_movimentacao_fora_prazo.sql +++ b/models/br_me_caged/br_me_caged__microdados_movimentacao_fora_prazo.sql @@ -12,9 +12,13 @@ pre_hook="DROP ALL ROW ACCESS POLICIES ON {{ this }}", ) }} + + select safe_cast(ano as int64) ano, safe_cast(mes as int64) mes, + safe_cast(SUBSTRING(competenciamov, 1, 4) as int64) ano_competencia_movimentacao, + safe_cast(SUBSTRING(competenciamov, 5, 6) as int64) mes_competencia_movimentacao, safe_cast(a.sigla_uf as string) sigla_uf, safe_cast(b.id_municipio as string) id_municipio, safe_cast(cnae_2_secao as string) cnae_2_secao, @@ -48,7 +52,7 @@ select safe_cast(indicador_fora_prazo as int64) indicador_fora_prazo from `basedosdados-dev.br_me_caged_staging.microdados_movimentacao_fora_prazo` a left join - `basedosdados-dev.br_bd_diretorios_brasil.municipio` b + `basedosdados.br_bd_diretorios_brasil.municipio` b on a.id_municipio = b.id_municipio_6 {% if is_incremental() %} where