From d993bcf3be133c0eac72e8dd3f3ef597f053c07a Mon Sep 17 00:00:00 2001 From: uiro-bi Date: Thu, 7 Nov 2024 16:19:09 -0300 Subject: [PATCH] fix: change incremental logic to rematerializa specific partitions --- models/br_me_cnpj/br_me_cnpj__empresas.sql | 2 +- models/br_me_cnpj/br_me_cnpj__estabelecimentos.sql | 2 +- models/br_me_cnpj/br_me_cnpj__socios.sql | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/models/br_me_cnpj/br_me_cnpj__empresas.sql b/models/br_me_cnpj/br_me_cnpj__empresas.sql index 271ceb86..90f44b9b 100644 --- a/models/br_me_cnpj/br_me_cnpj__empresas.sql +++ b/models/br_me_cnpj/br_me_cnpj__empresas.sql @@ -31,4 +31,4 @@ with ) select * from cnpj_empresas -{% if is_incremental() %} where data > (select max(data) from {{ this }}) {% endif %} +{% if is_incremental() %} where data > '2024-09-01' {% endif %} diff --git a/models/br_me_cnpj/br_me_cnpj__estabelecimentos.sql b/models/br_me_cnpj/br_me_cnpj__estabelecimentos.sql index a971fdc3..0d3541e0 100644 --- a/models/br_me_cnpj/br_me_cnpj__estabelecimentos.sql +++ b/models/br_me_cnpj/br_me_cnpj__estabelecimentos.sql @@ -63,4 +63,4 @@ with ) select * from cnpj_estabelecimentos -{% if is_incremental() %} where data > (select max(data) from {{ this }}) {% endif %} +{% if is_incremental() %} where data > '2024-09-01' {% endif %} diff --git a/models/br_me_cnpj/br_me_cnpj__socios.sql b/models/br_me_cnpj/br_me_cnpj__socios.sql index 31ce02a4..64c6c46c 100644 --- a/models/br_me_cnpj/br_me_cnpj__socios.sql +++ b/models/br_me_cnpj/br_me_cnpj__socios.sql @@ -36,4 +36,4 @@ with ) select * from cnpj_socios -{% if is_incremental() %} where data > (select max(data) from {{ this }}) {% endif %} +{% if is_incremental() %} where data > '2024-09-01' {% endif %}