Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Aug 23, 2024
1 parent 0b3d408 commit 23e317d
Show file tree
Hide file tree
Showing 4 changed files with 38 additions and 39 deletions.
62 changes: 31 additions & 31 deletions pipelines/ergon/dump_db_ergon/schedules.py
Original file line number Diff line number Diff line change
Expand Up @@ -513,19 +513,19 @@
"materialization_mode": "prod",
"dump_mode": "overwrite",
"execute_query": """
SELECT
CHAVE, CHAVE_VAGA, IDENTIFICACAO, NOME,
NUMVINC, NUMFUNC, CONVOCACAO, NOMEACAO, POSSE,
DESISTENCIA, CLASSIFICACAO, DEFICIENTE, SEXO, DATA_NASCIMENTO,
ESTADO_CIVIL, TIPORG, ORGAORG, NUMRG, UFRG, CPF, TIPOLOGENDER, NOMELOGENDER,
NUMENDER, COMPLENDER, BAIRROENDER, CIDADEENDER, UFENDER, CEPENDER,
PONTOS_TITULO, EMP_CODIGO, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03,
FLEX_CAMPO_04, FLEX_CAMPO_05, NACIONALIDADE, ORDEM_CHAMADA, SETOR, PONTPUBL,
DT_EMISSAO_RG, FLEX_CAMPO_06, FLEX_CAMPO_07, FLEX_CAMPO_08, FLEX_CAMPO_09,
FLEX_CAMPO_10, FLEX_CAMPO_11, FLEX_CAMPO_12, FLEX_CAMPO_13, FLEX_CAMPO_14,
FLEX_CAMPO_15, TELEFONE, ID_PESSOA, ID_COTAS_CONCURSOS, FLEX_CAMPO_16,
FLEX_CAMPO_17, FLEX_CAMPO_18, FLEX_CAMPO_19, FLEX_CAMPO_20, FLEX_CAMPO_21,
FLEX_CAMPO_22, FLEX_CAMPO_23, FLEX_CAMPO_24, FLEX_CAMPO_25, FLEX_CAMPO_26,
SELECT
CHAVE, CHAVE_VAGA, IDENTIFICACAO, NOME,
NUMVINC, NUMFUNC, CONVOCACAO, NOMEACAO, POSSE,
DESISTENCIA, CLASSIFICACAO, DEFICIENTE, SEXO, DATA_NASCIMENTO,
ESTADO_CIVIL, TIPORG, ORGAORG, NUMRG, UFRG, CPF, TIPOLOGENDER, NOMELOGENDER,
NUMENDER, COMPLENDER, BAIRROENDER, CIDADEENDER, UFENDER, CEPENDER,
PONTOS_TITULO, EMP_CODIGO, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03,
FLEX_CAMPO_04, FLEX_CAMPO_05, NACIONALIDADE, ORDEM_CHAMADA, SETOR, PONTPUBL,
DT_EMISSAO_RG, FLEX_CAMPO_06, FLEX_CAMPO_07, FLEX_CAMPO_08, FLEX_CAMPO_09,
FLEX_CAMPO_10, FLEX_CAMPO_11, FLEX_CAMPO_12, FLEX_CAMPO_13, FLEX_CAMPO_14,
FLEX_CAMPO_15, TELEFONE, ID_PESSOA, ID_COTAS_CONCURSOS, FLEX_CAMPO_16,
FLEX_CAMPO_17, FLEX_CAMPO_18, FLEX_CAMPO_19, FLEX_CAMPO_20, FLEX_CAMPO_21,
FLEX_CAMPO_22, FLEX_CAMPO_23, FLEX_CAMPO_24, FLEX_CAMPO_25, FLEX_CAMPO_26,
FLEX_CAMPO_27, FLEX_CAMPO_28, FLEX_CAMPO_29, FLEX_CAMPO_30
FROM ERGON.INSCRITOS
""",
Expand All @@ -536,12 +536,12 @@
"materialization_mode": "prod",
"dump_mode": "overwrite",
"execute_query": """
SELECT
CHAVE, CHAVE_CONCURSO, CARGO, ESPECIALIDADE, HLOCAL, QTD_VAGAS,
QTD_VAGAS_DEF, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03,
FLEX_CAMPO_04, FLEX_CAMPO_05, EMP_CODIGO, SEXO, PERCENTUAL_VAGAS_DEF,
DIAS_PRAZO_POSSE, DIAS_PRAZO_PRORROG_POSSE, DIAS_PRAZO_EXERC,
DIAS_PRAZO_PRORROG_EXERC, GRUPO_VAGAS, FLEX_CAMPO_06, FLEX_CAMPO_07,
SELECT
CHAVE, CHAVE_CONCURSO, CARGO, ESPECIALIDADE, HLOCAL, QTD_VAGAS,
QTD_VAGAS_DEF, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03,
FLEX_CAMPO_04, FLEX_CAMPO_05, EMP_CODIGO, SEXO, PERCENTUAL_VAGAS_DEF,
DIAS_PRAZO_POSSE, DIAS_PRAZO_PRORROG_POSSE, DIAS_PRAZO_EXERC,
DIAS_PRAZO_PRORROG_EXERC, GRUPO_VAGAS, FLEX_CAMPO_06, FLEX_CAMPO_07,
FLEX_CAMPO_08, FLEX_CAMPO_09, FLEX_CAMPO_10
FROM ERGON.VAGAS_CONCURSO
""",
Expand All @@ -552,13 +552,13 @@
"materialization_mode": "prod",
"dump_mode": "overwrite",
"execute_query": """
SELECT
CHAVE, SIGLA, REGIMEJUR, DTINI, VALIDADE, PUBLIC_EDITAL, RESULTADO,
OBJETIVO, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03, FLEX_CAMPO_04,
FLEX_CAMPO_05, EMP_CODIGO, PRORROGACAO, CANCELAMENTO, ABRANGENCIA,
PONTPUBL, DTINI_INSCRICAO, DTFIM_INSCRICAO, SETOR, TIPO_CONCURSO,
TIPOVINC, INSTITUICAO, DIAS_PRAZO_POSSE, DIAS_PRAZO_PRORROG_POSSE,
DIAS_PRAZO_EXERC, DIAS_PRAZO_PRORROG_EXERC, FLEX_CAMPO_06, FLEX_CAMPO_07,
SELECT
CHAVE, SIGLA, REGIMEJUR, DTINI, VALIDADE, PUBLIC_EDITAL, RESULTADO,
OBJETIVO, FLEX_CAMPO_01, FLEX_CAMPO_02, FLEX_CAMPO_03, FLEX_CAMPO_04,
FLEX_CAMPO_05, EMP_CODIGO, PRORROGACAO, CANCELAMENTO, ABRANGENCIA,
PONTPUBL, DTINI_INSCRICAO, DTFIM_INSCRICAO, SETOR, TIPO_CONCURSO,
TIPOVINC, INSTITUICAO, DIAS_PRAZO_POSSE, DIAS_PRAZO_PRORROG_POSSE,
DIAS_PRAZO_EXERC, DIAS_PRAZO_PRORROG_EXERC, FLEX_CAMPO_06, FLEX_CAMPO_07,
FLEX_CAMPO_08, FLEX_CAMPO_09, FLEX_CAMPO_10
FROM ERGON.CONCURSOS
""",
Expand All @@ -569,11 +569,11 @@
"materialization_mode": "prod",
"dump_mode": "overwrite",
"execute_query": """
SELECT
FLEX_CAMPO_05, FLEX_CAMPO_04, FLEX_CAMPO_03, FLEX_CAMPO_02, FLEX_CAMPO_01,
NOME, SIGLA, FLEX_CAMPO_20, FLEX_CAMPO_19, FLEX_CAMPO_18, FLEX_CAMPO_17,
FLEX_CAMPO_16, FLEX_CAMPO_15, FLEX_CAMPO_06, FLEX_CAMPO_14, FLEX_CAMPO_13,
FLEX_CAMPO_12, FLEX_CAMPO_11, FLEX_CAMPO_10, FLEX_CAMPO_09, FLEX_CAMPO_08,
SELECT
FLEX_CAMPO_05, FLEX_CAMPO_04, FLEX_CAMPO_03, FLEX_CAMPO_02, FLEX_CAMPO_01,
NOME, SIGLA, FLEX_CAMPO_20, FLEX_CAMPO_19, FLEX_CAMPO_18, FLEX_CAMPO_17,
FLEX_CAMPO_16, FLEX_CAMPO_15, FLEX_CAMPO_06, FLEX_CAMPO_14, FLEX_CAMPO_13,
FLEX_CAMPO_12, FLEX_CAMPO_11, FLEX_CAMPO_10, FLEX_CAMPO_09, FLEX_CAMPO_08,
FLEX_CAMPO_07, PONTLEI, CODIGO_CAGED
FROM ERGON.FORMAS_VAC
""",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
)

from pipelines.constants import constants

from pipelines.receita_federal_cnpj.dump_db_porte_empresa.schedules import (
porte_empresa_schedule,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
"dump_mode": "append",
"lower_bound_date": "current_month",
"execute_query": """
SELECT
CNPJ_basico, CNPJ_ordem, CNPJ_dv, RazaoSocial,
SELECT
CNPJ_basico, CNPJ_ordem, CNPJ_dv, RazaoSocial,
cd_PorteEmpresa, cd_SituacaoCadastral, dt_SituacaoCadastral
FROM SDI.ReceitaFederal.Vw_PorteEmpresa_Sigma;
""",
Expand Down
10 changes: 5 additions & 5 deletions queries/models/porte_empresa/situacao_cadastral.sql
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,13 @@
}
)
}}
SELECT
SAFE_CAST(cnpj_basico AS STRING) AS cnpj_basico,
SELECT
SAFE_CAST(cnpj_basico AS STRING) AS cnpj_basico,
SAFE_CAST(cnpj_ordem AS STRING) AS cnpj_ordem,
SAFE_CAST(cnpj_dv AS STRING) AS cnpj_dv,
SAFE_CAST(razaosocial AS STRING) AS razao_social,
SAFE_CAST(cnpj_dv AS STRING) AS cnpj_dv,
SAFE_CAST(razaosocial AS STRING) AS razao_social,
SAFE_CAST(REGEXP_REPLACE(cd_porteempresa, r'\.0$', '') AS STRING) AS id_porte_empresa,
SAFE_CAST(REGEXP_REPLACE(cd_situacaocadastral, r'\.0$', '') AS STRING) AS id_situacao_cadastral,
SAFE_CAST(REGEXP_REPLACE(cd_situacaocadastral, r'\.0$', '') AS STRING) AS id_situacao_cadastral,
SAFE_CAST(dt_situacaocadastral AS DATE) AS data_situacao_cadastral
SAFE_CAST(data_particao AS DATE) data_particao
FROM `rj-smfp.porte_empresa_staging.situacao_cadastral`

0 comments on commit 23e317d

Please sign in to comment.