Merge pull request #22 from prefeitura-rio/staging/add-dw-bi-alvaras

fix: Change models to correct dataset

pipelines/atividade_economica/dump_db/flows.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 """
-Database dumping flows for alvaras.
+Database dumping flows for alvaras....
 """
 
 from copy import deepcopy

pipelines/ergon/dump_db_ergon/flows.py

@@ -1,6 +1,10 @@
 # -*- coding: utf-8 -*-
 """
+<<<<<<< HEAD
+Database dumping flows for segovi project..........
+=======
 Database dumping flows for segovi project.....
+>>>>>>> 9248dea3c889cc0dd0466f8c2e75465ca1dbf796
 """
 
 from copy import deepcopy

pipelines/templates/run_dbt_model/flows.py

@@ -1,6 +1,10 @@
 # -*- coding: utf-8 -*-
 """
+<<<<<<< HEAD
+MATERIALIZA MODELOS DO DBT..............
+=======
 MATERIALIZA MODELOS DO DBT...
+>>>>>>> 9248dea3c889cc0dd0466f8c2e75465ca1dbf796
 """
 
 from copy import deepcopy

queries/models/atividade_economica/fact_fatoalvaras.sql

@@ -11,4 +11,4 @@ SELECT
     SAFE_CAST(ID_TipoContribuint AS STRING) AS ID_TipoContribuint,
     SAFE_CAST(ID_TipoSolicitacao AS STRING) AS ID_TipoSolicitacao
 
-FROM `rj-iplanrio.alvaras_staging.fact_fatoalvaras`
+FROM `rj-smfp.atividade_economica_staging.fact_fatoalvaras`

queries/models/atividade_economica/fact_fatocp.sql

@@ -9,4 +9,4 @@ SELECT
     SAFE_CAST(ID_TipoContribuint AS STRING) AS ID_TipoContribuint,
     SAFE_CAST(ID_TipoSolicitacao AS STRING) AS ID_TipoSolicitacao
 
-FROM `rj-iplanrio.alvaras_staging.fact_fatocp`
+FROM `rj-smfp.atividade_economica_staging.fact_fatocp`

queries/models/atividade_economica/tab_alvara.sql

@@ -19,4 +19,4 @@ SELECT
     SAFE_CAST(DSC_Numero AS FLOAT64) AS DSC_Numero,
     SAFE_CAST(DSC_AlvaraLiberado AS STRING) AS DSC_AlvaraLiberado
 
-FROM `rj-iplanrio.alvaras_staging.tab_alvara`
+FROM `rj-smfp.atividade_economica_staging.tab_alvara`

queries/models/atividade_economica/tab_atvprocesso.sql

@@ -4,4 +4,4 @@ SELECT
     SAFE_CAST(DSC_RespAtividade AS STRING) AS DSC_RespAtividade,
     SAFE_CAST(DSC_RefAtividade AS STRING) AS DSC_RefAtividade
 
-FROM `rj-iplanrio.alvaras_staging.tab_atvprocesso`
+FROM `rj-smfp.atividade_economica_staging.tab_atvprocesso`

queries/models/atividade_economica/tab_cae.sql

@@ -4,4 +4,4 @@ SELECT
     SAFE_CAST(ID_TipoAtividade AS STRING) AS ID_TipoAtividade,
     SAFE_CAST(DSC_TipoAtividade AS STRING) AS DSC_TipoAtividade
 
-FROM `rj-iplanrio.alvaras_staging.tab_cae`
+FROM `rj-smfp.atividade_economica_staging.tab_cae`

queries/models/atividade_economica/tab_cnae.sql

@@ -2,4 +2,4 @@ SELECT
     SAFE_CAST(ID_CNAE AS STRING) AS ID_CNAE,
     SAFE_CAST(DSC_CNAE AS STRING) AS DSC_CNAE
 
-FROM `rj-iplanrio.alvaras_staging.tab_cnae`
+FROM `rj-smfp.atividade_economica_staging.tab_cnae`

queries/models/atividade_economica/tab_consulta.sql

@@ -10,4 +10,4 @@ SELECT
     SAFE_CAST(DSC_TipoAnalise_cp AS STRING) AS DSC_TipoAnalise_cp,
     SAFE_CAST(DSC_Status_cp AS STRING) AS DSC_Status_cp
 
-FROM `rj-iplanrio.alvaras_staging.tab_consulta`
+FROM `rj-smfp.atividade_economica_staging.tab_consulta`

queries/models/atividade_economica/tab_direcionamento.sql

@@ -2,4 +2,4 @@ SELECT
     SAFE_CAST(ID_Direcionamento AS STRING) AS ID_Direcionamento,
     SAFE_CAST(DSC_Direcionamento AS STRING) AS DSC_Direcionamento
 
-FROM `rj-iplanrio.alvaras_staging.tab_direcionamento`
+FROM `rj-smfp.atividade_economica_staging.tab_direcionamento`

queries/models/atividade_economica/tab_tipocontribuinte_tipocontribuint.sql

@@ -1,4 +1,4 @@
 SELECT
     SAFE_CAST(ID_TipoContribuint AS STRING) AS ID_TipoContribuint,
     SAFE_CAST(DSC_TipoContribuint AS STRING) AS DSC_TipoContribuint
-FROM `rj-iplanrio.alvaras_staging.tab_tipocontribuinte_tipocontribuint`
+FROM `rj-smfp.atividade_economica_staging.tab_tipocontribuinte_tipocontribuint`

queries/models/atividade_economica/tab_tiposolicitacao.sql

@@ -2,4 +2,4 @@ SELECT
     SAFE_CAST(ID_TipoSolicitacao AS STRING) AS ID_TipoSolicitacao,
     SAFE_CAST(DSC_TipoSolicitacao AS STRING) AS DSC_TipoSolicitacao
 
-FROM `rj-iplanrio.alvaras_staging.tab_tiposolicitacao`
+FROM `rj-smfp.atividade_economica_staging.tab_tiposolicitacao`