chore: change some tables from incremental to table

prefeitura-rio · Jan 12, 2024 · 3ef6d70 · 3ef6d70
1 parent 2f70a56
commit 3ef6d70
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 29 deletions.
diff --git a/queries/models/recursos_humanos_ergon/ficha_financeira.sql b/queries/models/recursos_humanos_ergon/ficha_financeira.sql
@@ -1,8 +1,6 @@
 {{
     config(
-        alias='ficha_financeira',
-        schema='recursos_humanos_ergon',
-        materialized='incremental',
+        materialized='table',
         partition_by={
             "field": "data_particao",
             "data_type": "date",
@@ -27,14 +25,14 @@ SELECT
     SAFE_CAST(REGEXP_REPLACE(TRIM(emp_codigo), r'\.0$', '') AS STRING) AS emp_codigo,
     SAFE_CAST(data_particao AS DATE) data_particao,
 FROM rj-smfp.recursos_humanos_ergon_staging.ficha_financeira AS t
-WHERE
-    SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
+-- WHERE
+--     SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
 
-{% if is_incremental() %}
+-- {% if is_incremental() %}
 
-{% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
+-- {% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
 
-AND
-    SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
+-- AND
+--     SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
 
-{% endif %}
+-- {% endif %}
diff --git a/queries/models/recursos_humanos_ergon/ficha_financeira_contabil.sql b/queries/models/recursos_humanos_ergon/ficha_financeira_contabil.sql
@@ -1,6 +1,6 @@
 {{
     config(
-        materialized='incremental',
+        materialized='table',
         partition_by={
             "field": "data_particao",
             "data_type": "date",
@@ -30,14 +30,14 @@ SELECT
     SAFE_CAST(REGEXP_REPLACE(TRIM(emp_codigo), r'.0$', '') AS STRING) AS emp_codigo,
     SAFE_CAST(data_particao AS DATE) data_particao,
 FROM rj-smfp.recursos_humanos_ergon_staging.ficha_financeira_contabil AS t
-WHERE
-    SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
+-- WHERE
+--     SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
 
-{% if is_incremental() %}
+-- {% if is_incremental() %}
 
-{% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
+-- {% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
 
-AND
-    SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
+-- AND
+--     SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
 
-{% endif %}
+-- {% endif %}
diff --git a/queries/models/recursos_humanos_ergon/fita_banco.sql b/queries/models/recursos_humanos_ergon/fita_banco.sql
@@ -1,8 +1,6 @@
 {{
     config(
-        alias='fita_banco',
-        schema='recursos_humanos_ergon',
-        materialized='incremental',
+        materialized='table',
         partition_by={
             "field": "data_particao",
             "data_type": "date",
@@ -44,15 +42,15 @@ SELECT
     SAFE_CAST(REGEXP_REPLACE(flex_campo_05, r'\.0$', '') AS STRING) AS flex_campo_05,
     SAFE_CAST(REGEXP_REPLACE(jornada, r'\.0$', '') AS STRING) AS jornada,
     SAFE_CAST(data_particao AS DATE) data_particao,
-    FROM rj-smfp.recursos_humanos_ergon_staging.fita_banco AS t
-WHERE
-    SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
+FROM rj-smfp.recursos_humanos_ergon_staging.fita_banco AS t
+-- WHERE
+--     SAFE_CAST(data_particao AS DATE) < CURRENT_DATE('America/Sao_Paulo')
 
-{% if is_incremental() %}
+-- {% if is_incremental() %}
 
-{% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
+-- {% set max_partition = run_query("SELECT gr FROM (SELECT IF(max(data_particao) > CURRENT_DATE('America/Sao_Paulo'), CURRENT_DATE('America/Sao_Paulo'), max(data_particao)) as gr FROM " ~ this ~ ")").columns[0].values()[0] %}
 
-AND
-    SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
+-- AND
+--     SAFE_CAST(data_particao AS DATE) > ("{{ max_partition }}")
 
-{% endif %}
+-- {% endif %}