Merge branch 'master' into staging/br_geobr_mapas.bioma

basedosdados · Sep 26, 2023 · a20f885 · a20f885
2 parents 270d879 + 832c12b
commit a20f885
Show file tree

Hide file tree

Showing 14 changed files with 552 additions and 20 deletions.
diff --git a/models/br_ibge_inpc/br_ibge_inpc__mes_brasil.sql b/models/br_ibge_inpc/br_ibge_inpc__mes_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_brasil', schema='br_ibge_inpc') }}
+{{ 
+    config(
+        alias='mes_brasil', 
+        schema='br_ibge_inpc',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -9,3 +24,6 @@ SAFE_CAST(variacao_semestral AS FLOAT64) variacao_semestral,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
 FROM basedosdados-staging.br_ibge_inpc_staging.mes_brasil AS t
+{% 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/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_brasil.sql b/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_brasil', schema='br_ibge_inpc') }}
+{{ 
+    config(
+        alias='mes_categoria_brasil', 
+        schema='br_ibge_inpc',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,3 +25,6 @@ SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
 FROM basedosdados-staging.br_ibge_inpc_staging.mes_categoria_brasil AS t
+{% 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/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_municipio.sql b/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_municipio.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_municipio', schema='br_ibge_inpc') }}
+{{ 
+    config(
+        alias='mes_categoria_municipio', 
+        schema='br_ibge_inpc',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +25,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_inpc_staging.mes_categoria_municipio AS t
+FROM basedosdados-staging.br_ibge_inpc_staging.mes_categoria_municipio AS t
+{% 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/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_rm.sql b/models/br_ibge_inpc/br_ibge_inpc__mes_categoria_rm.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_rm', schema='br_ibge_inpc') }}
+{{ 
+    config(
+        alias='mes_categoria_rm', 
+        schema='br_ibge_inpc',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +25,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_inpc_staging.mes_categoria_rm AS t
+FROM basedosdados-staging.br_ibge_inpc_staging.mes_categoria_rm AS t
+{% 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/models/br_ibge_ipca/br_ibge_ipca__mes_brasil.sql b/models/br_ibge_ipca/br_ibge_ipca__mes_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_brasil', schema='br_ibge_ipca') }}
+{{ 
+    config(
+        alias='mes_brasil', 
+        schema='br_ibge_ipca',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -9,3 +24,7 @@ SAFE_CAST(variacao_semestral AS FLOAT64) variacao_semestral,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
 FROM basedosdados-staging.br_ibge_ipca_staging.mes_brasil AS t
+
+{% 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/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_brasil.sql b/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_brasil', schema='br_ibge_ipca') }}
+{{ 
+    config(
+        alias='mes_categoria_brasil', 
+        schema='br_ibge_ipca',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -9,4 +24,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_brasil AS t
+FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_brasil AS t
+{% 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/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_municipio.sql b/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_municipio.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_municipio', schema='br_ibge_ipca') }}
+{{ 
+    config(
+        alias='mes_categoria_municipio', 
+        schema='br_ibge_ipca',
+        materialized='incremental',
+    pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+    post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                    ON {{this}}
+                    GRANT TO ("allUsers")
+                FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+              'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                    ON  {{this}}
+                    GRANT TO ("group:[email protected]", "group:[email protected]")
+                    FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +25,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_municipio AS t
+FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_municipio AS t
+{% 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/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_rm.sql b/models/br_ibge_ipca/br_ibge_ipca__mes_categoria_rm.sql
@@ -1,4 +1,20 @@
-{{ config(alias='mes_categoria_rm', schema='br_ibge_ipca') }}
+{{ 
+  config(
+      alias='mes_categoria_rm', 
+      schema='br_ibge_ipca',
+      materialized='incremental',
+  pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+  post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                  ON {{this}}
+                  GRANT TO ("allUsers")
+              FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+            'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                  ON  {{this}}
+                  GRANT TO ("group:[email protected]", "group:[email protected]")
+                  FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
+
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +26,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_rm AS t
+FROM basedosdados-staging.br_ibge_ipca_staging.mes_categoria_rm AS t
+{% 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/models/br_ibge_ipca15/br_ibge_ipca15__mes_brasil.sql b/models/br_ibge_ipca15/br_ibge_ipca15__mes_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_brasil', schema='br_ibge_ipca15') }}
+{{ 
+  config(
+      alias='mes_brasil', 
+      schema='br_ibge_ipca15',
+      materialized='incremental',
+  pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+  post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                  ON {{this}}
+                  GRANT TO ("allUsers")
+              FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+            'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                  ON  {{this}}
+                  GRANT TO ("group:[email protected]", "group:[email protected]")
+                  FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -9,3 +24,6 @@ SAFE_CAST(variacao_semestral AS FLOAT64) variacao_semestral,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
 FROM basedosdados-staging.br_ibge_ipca15_staging.mes_brasil AS t
+{% 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/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_brasil.sql b/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_brasil.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_brasil', schema='br_ibge_ipca15') }}
+{{ 
+  config(
+      alias='mes_categoria_brasil', 
+      schema='br_ibge_ipca15',
+      materialized='incremental',
+  pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+  post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                  ON {{this}}
+                  GRANT TO ("allUsers")
+              FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+            'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                  ON  {{this}}
+                  GRANT TO ("group:[email protected]", "group:[email protected]")
+                  FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -9,4 +24,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_brasil AS t
+FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_brasil AS t
+{% 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/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_municipio.sql b/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_municipio.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_municipio', schema='br_ibge_ipca15') }}
+{{ 
+  config(
+      alias='mes_categoria_municipio', 
+      schema='br_ibge_ipca15',
+      materialized='incremental',
+  pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+  post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                  ON {{this}}
+                  GRANT TO ("allUsers")
+              FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+            'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                  ON  {{this}}
+                  GRANT TO ("group:[email protected]", "group:[email protected]")
+                  FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +25,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_municipio AS t
+FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_municipio AS t
+{% 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/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_rm.sql b/models/br_ibge_ipca15/br_ibge_ipca15__mes_categoria_rm.sql
@@ -1,4 +1,19 @@
-{{ config(alias='mes_categoria_rm', schema='br_ibge_ipca15') }}
+{{ 
+  config(
+      alias='mes_categoria_rm', 
+      schema='br_ibge_ipca15',
+      materialized='incremental',
+  pre_hook = "DROP ALL ROW ACCESS POLICIES ON {{ this }}",
+  post_hook=['CREATE OR REPLACE ROW ACCESS POLICY allusers_filter 
+                  ON {{this}}
+                  GRANT TO ("allUsers")
+              FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) > 6)',
+            'CREATE OR REPLACE ROW ACCESS POLICY bdpro_filter 
+                  ON  {{this}}
+                  GRANT TO ("group:[email protected]", "group:[email protected]")
+                  FILTER USING (DATE_DIFF(DATE("{{ run_started_at.strftime("%Y-%m-%d") }}"),DATE(CAST(ano AS INT64),CAST(mes AS INT64),1), MONTH) <= 6)']
+  )
+}}
 SELECT 
 SAFE_CAST(ano AS INT64) ano,
 SAFE_CAST(mes AS INT64) mes,
@@ -10,4 +25,7 @@ SAFE_CAST(peso_mensal AS FLOAT64) peso_mensal,
 SAFE_CAST(variacao_mensal AS FLOAT64) variacao_mensal,
 SAFE_CAST(variacao_anual AS FLOAT64) variacao_anual,
 SAFE_CAST(variacao_doze_meses AS FLOAT64) variacao_doze_meses
-FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_rm AS t
+FROM basedosdados-staging.br_ibge_ipca15_staging.mes_categoria_rm AS t
+{% 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/models/br_inep_enem/br_inep_enem__dicionario.sql b/models/br_inep_enem/br_inep_enem__dicionario.sql
@@ -0,0 +1,14 @@
+{{
+    config(
+        alias='dicionario',
+        schema='br_inep_enem'
+    )
+}}
+
+SELECT
+SAFE_CAST(id_tabela AS STRING) id_tabela,
+SAFE_CAST(nome_coluna AS STRING) nome_coluna,
+SAFE_CAST(chave AS STRING) chave,
+SAFE_CAST(cobertura_temporal AS STRING) cobertura_temporal,
+SAFE_CAST(valor AS STRING) valor
+FROM basedosdados-staging.br_inep_enem_staging.dicionario AS t