feat: udpate caged dbt models

basedosdados · Nov 28, 2024 · 1e658a9 · 1e658a9
1 parent 625d86e
commit 1e658a9
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 2 deletions.
diff --git a/...s/br_me_caged/microdados_movimentacao.sql → .../br_me_caged__microdados_movimentacao.sql b/...s/br_me_caged/microdados_movimentacao.sql → .../br_me_caged__microdados_movimentacao.sql
@@ -1,7 +1,8 @@
 {{
     config(
         schema="br_me_caged",
-        materialized="table",
+        materialized="incremental",
+        alias="movimentacao",
         partition_by={
             "field": "ano",
             "data_type": "int64",
@@ -12,6 +13,7 @@
         pre_hook="DROP ALL ROW ACCESS POLICIES ON {{ this }}",
     )
 }}
+
 select
     safe_cast(ano as int64) ano,
     safe_cast(mes as int64) mes,
@@ -50,3 +52,9 @@ from `basedosdados-staging.br_me_caged_staging.microdados_movimentacao` a
 left join
     `basedosdados.br_bd_diretorios_brasil.municipio` b
     on a.id_municipio = b.id_municipio_6
+
+{% if is_incremental() %}
+    where
+        date(cast(ano as int64), cast(mes as int64), 1)
+        > (select max(date(cast(ano as int64), cast(mes as int64), 1)) from {{ this }})
+{% endif %}
diff --git a/...aged/microdados_movimentacao_excluida.sql → ...ged__microdados_movimentacao_excluida.sql b/...aged/microdados_movimentacao_excluida.sql → ...ged__microdados_movimentacao_excluida.sql
@@ -2,6 +2,7 @@
     config(
         schema="br_me_caged",
         materialized="table",
+        alias="movimentacao_excluida",
         partition_by={
             "field": "ano",
             "data_type": "int64",

diff --git a/...ed/microdados_movimentacao_fora_prazo.sql → .../br_me_caged__movimentacao_fora_prazo.sql b/...ed/microdados_movimentacao_fora_prazo.sql → .../br_me_caged__movimentacao_fora_prazo.sql
@@ -2,6 +2,7 @@
     config(
         schema="br_me_caged",
         materialized="table",
+        alias="movimentacao_fora_prazo",
         partition_by={
             "field": "ano",
             "data_type": "int64",

diff --git a/models/br_me_caged/schema.yml b/models/br_me_caged/schema.yml
@@ -1,7 +1,7 @@
 ---
 version: 2
 models:
-  - name: microdados_movimentacao
+  - name: br_me_caged__microdados_movimentacao
     description: Contém dados de movimentações declaradas dentro do prazo com competência
       de declaração.
     tests: