From d0aec47d6c45615ca1405190c9bfbe13f8c5ba68 Mon Sep 17 00:00:00 2001 From: tricktx Date: Thu, 14 Mar 2024 11:02:42 -0300 Subject: [PATCH] revert commit in tables part 2 --- ...cgu_beneficios_cidadao__auxilio_brasil.sql | 2 +- ...icios_cidadao__bolsa_familia_pagamento.sql | 4 +--- .../br_cgu_beneficios_cidadao__bpc.sql | 21 ++++++++++++++++++- ...cgu_beneficios_cidadao__garantia_safra.sql | 21 ++++++++++++++++++- ...beneficios_cidadao__novo_bolsa_familia.sql | 21 ++++++++++++++++++- 5 files changed, 62 insertions(+), 7 deletions(-) diff --git a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__auxilio_brasil.sql b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__auxilio_brasil.sql index 9cdc9fbd..d7780384 100644 --- a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__auxilio_brasil.sql +++ b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__auxilio_brasil.sql @@ -27,4 +27,4 @@ select distinct safe_cast(nis as string) nis_favorecido, safe_cast(nome as string) nome_favorecido, safe_cast(valor_beneficio as float64) valor_parcela, -from `basedosdados-staging.br_cgu_beneficios_cidadao_staging.auxilio_brasil` as t +from `basedosdados-dev.br_cgu_beneficios_cidadao_staging.auxilio_brasil` as t diff --git a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bolsa_familia_pagamento.sql b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bolsa_familia_pagamento.sql index 2bfc0534..d23b115f 100644 --- a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bolsa_familia_pagamento.sql +++ b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bolsa_familia_pagamento.sql @@ -27,6 +27,4 @@ select distinct safe_cast(nis as string) nis_favorecido, safe_cast(nome as string) nome_favorecido, safe_cast(valor_beneficio as float64) valor_parcela, -from - `basedosdados-staging.br_cgu_beneficios_cidadao_staging.bolsa_familia_pagamento` - as t +from `basedosdados-dev.br_cgu_beneficios_cidadao_staging.bolsa_familia_pagamento` as t diff --git a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bpc.sql b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bpc.sql index f1f7172f..cda77123 100644 --- a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bpc.sql +++ b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__bpc.sql @@ -41,7 +41,7 @@ with on safe_cast(t1.id_municipio_siafi as int64) = safe_cast(t2.id_municipio_rf as int64) ) -select * except (data) +select * except (data) << << << < head from bpc << << << < head {% if is_incremental() %} where data > (select max(data) from {{ this }}) @@ -53,3 +53,22 @@ from bpc << << << < head add materialized incremental tables in novo_bolsa_familia, garantia_safra and bpc ) + == == + == = +from + bpc + {% if is_incremental() %} + date(cast(ano_competencia as int64), cast(mes_competencia as int64), 1) > ( + select + max( + date( + cast(ano_competencia as int64), + cast(mes_competencia as int64), + 1 + ) + ) + from {{ this }} + ) + {% endif %} + >> >> + >> > parent of d8643ab(fix bucket staging and incremental) diff --git a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__garantia_safra.sql b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__garantia_safra.sql index df274aef..0f4a7bbe 100644 --- a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__garantia_safra.sql +++ b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__garantia_safra.sql @@ -37,7 +37,7 @@ with on safe_cast(t1.id_municipio_siafi as int64) = safe_cast(t2.id_municipio_rf as int64) ) -select * except (data) +select * except (data) << << << < head from garantia_safra << << << < head {% if is_incremental() %} where data > (select max(data) from {{ this }}) @@ -49,3 +49,22 @@ from garantia_safra << << << < head add materialized incremental tables in novo_bolsa_familia, garantia_safra and bpc ) + == == + == = +from + garantia_safra + {% if is_incremental() %} + date(cast(ano_competencia as int64), cast(mes_competencia as int64), 1) > ( + select + max( + date( + cast(ano_competencia as int64), + cast(mes_competencia as int64), + 1 + ) + ) + from {{ this }} + ) + {% endif %} + >> >> + >> > parent of d8643ab(fix bucket staging and incremental) diff --git a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__novo_bolsa_familia.sql b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__novo_bolsa_familia.sql index 9f78a5a8..880feab8 100644 --- a/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__novo_bolsa_familia.sql +++ b/models/br_cgu_beneficios_cidadao/br_cgu_beneficios_cidadao__novo_bolsa_familia.sql @@ -37,7 +37,7 @@ with on safe_cast(t1.id_municipio_siafi as int64) = safe_cast(t2.id_municipio_rf as int64) ) -select * except (data) +select * except (data) << << << < head from novo_bolsa_familia << << << < head {% if is_incremental() %} where data > (select max(data) from {{ this }}) @@ -49,3 +49,22 @@ from novo_bolsa_familia << << << < head add materialized incremental tables in novo_bolsa_familia, garantia_safra and bpc ) + == == + == = +from + novo_bolsa_familia + {% if is_incremental() %} + date(cast(ano_competencia as int64), cast(mes_competencia as int64), 1) > ( + select + max( + date( + cast(ano_competencia as int64), + cast(mes_competencia as int64), + 1 + ) + ) + from {{ this }} + ) + {% endif %} + >> >> + >> > parent of d8643ab(fix bucket staging and incremental)