Merge pull request #862 from basedosdados/staging/fix_ibge_

[fix] br_ibge_
basedosdados · Sep 12, 2024 · 9311ce0 · 9311ce0
2 parents cc54479 + 2166f90
commit 9311ce0
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 13 deletions.
diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py
@@ -29,7 +29,7 @@
 
 br_ibge_inpc_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
 br_ibge_inpc_mes_categoria_brasil.name = "br_ibge_inpc.mes_categoria_brasil"
-br_ibge_inpc_mes_categoria_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_inpc_mes_categoria_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_inpc_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_inpc_mes_categoria_brasil.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -39,7 +39,7 @@
 
 br_ibge_inpc_mes_categoria_rm = deepcopy(flow_ibge_inflacao_mes_rm)
 br_ibge_inpc_mes_categoria_rm.name = "br_ibge_inpc.mes_categoria_rm"
-br_ibge_inpc_mes_categoria_rm.code_owners = ["equipe_pipelines"]
+br_ibge_inpc_mes_categoria_rm.code_owners = ["Gabriel Pisa"]
 br_ibge_inpc_mes_categoria_rm.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_inpc_mes_categoria_rm.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -48,7 +48,7 @@
 
 br_ibge_inpc_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
 br_ibge_inpc_mes_categoria_municipio.name = "br_ibge_inpc.mes_categoria_municipio"
-br_ibge_inpc_mes_categoria_municipio.code_owners = ["equipe_pipelines"]
+br_ibge_inpc_mes_categoria_municipio.code_owners = ["Gabriel Pisa"]
 br_ibge_inpc_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_inpc_mes_categoria_municipio.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -59,7 +59,7 @@
 
 br_ibge_inpc_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral)
 br_ibge_inpc_mes_brasil.name = "br_ibge_inpc.mes_brasil"
-br_ibge_inpc_mes_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_inpc_mes_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_inpc_mes_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_inpc_mes_brasil.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
 br_ibge_inpc_mes_brasil.schedule = schedule_br_ibge_inpc_mes_brasil
diff --git a/pipelines/datasets/br_ibge_inpc/schedules.py b/pipelines/datasets/br_ibge_inpc/schedules.py
@@ -65,7 +65,7 @@
 schedule_br_ibge_inpc_mes_categoria_municipio = Schedule(
     clocks=[
         CronClock(
-            cron="30 14 * * *",  # everyday at 14:00:00
+            cron="30 14 * * *",  # everyday at 14:30:00
             start_date=datetime(2023, 10, 6, 0, 0),
             labels=[
                 constants.BASEDOSDADOS_PROD_AGENT_LABEL.value,

diff --git a/pipelines/datasets/br_ibge_ipca/flows.py b/pipelines/datasets/br_ibge_ipca/flows.py
@@ -25,7 +25,7 @@
 
 br_ibge_ipca_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
 br_ibge_ipca_mes_categoria_brasil.name = "br_ibge_ipca.mes_categoria_brasil"
-br_ibge_ipca_mes_categoria_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_ipca_mes_categoria_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca_mes_categoria_brasil.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -35,7 +35,7 @@
 
 br_ibge_ipca_mes_categoria_rm = deepcopy(flow_ibge_inflacao_mes_rm)
 br_ibge_ipca_mes_categoria_rm.name = "br_ibge_ipca.mes_categoria_rm"
-br_ibge_ipca_mes_categoria_rm.code_owners = ["equipe_pipelines"]
+br_ibge_ipca_mes_categoria_rm.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca_mes_categoria_rm.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca_mes_categoria_rm.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -44,7 +44,7 @@
 
 br_ibge_ipca_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
 br_ibge_ipca_mes_categoria_municipio.name = "br_ibge_ipca.mes_categoria_municipio"
-br_ibge_ipca_mes_categoria_municipio.code_owners = ["equipe_pipelines"]
+br_ibge_ipca_mes_categoria_municipio.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca_mes_categoria_municipio.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -56,7 +56,7 @@
 
 br_ibge_ipca_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral)
 br_ibge_ipca_mes_brasil.name = "br_ibge_ipca.mes_brasil"
-br_ibge_ipca_mes_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_ipca_mes_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca_mes_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca_mes_brasil.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
 br_ibge_ipca_mes_brasil.schedule = schedule_br_ibge_ipca_mes_brasil
diff --git a/pipelines/datasets/br_ibge_ipca15/flows.py b/pipelines/datasets/br_ibge_ipca15/flows.py
@@ -29,7 +29,7 @@
 
 br_ibge_ipca15_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
 br_ibge_ipca15_mes_categoria_brasil.name = "br_ibge_ipca15.mes_categoria_brasil"
-br_ibge_ipca15_mes_categoria_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_ipca15_mes_categoria_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca15_mes_categoria_brasil.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -41,7 +41,7 @@
 
 br_ibge_ipca15_mes_categoria_rm = deepcopy(flow_ibge_inflacao_mes_rm)
 br_ibge_ipca15_mes_categoria_rm.name = "br_ibge_ipca15.mes_categoria_rm"
-br_ibge_ipca15_mes_categoria_rm.code_owners = ["equipe_pipelines"]
+br_ibge_ipca15_mes_categoria_rm.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_categoria_rm.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca15_mes_categoria_rm.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -50,7 +50,7 @@
 
 br_ibge_ipca15_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
 br_ibge_ipca15_mes_categoria_municipio.name = "br_ibge_ipca15.mes_categoria_municipio"
-br_ibge_ipca15_mes_categoria_municipio.code_owners = ["equipe_pipelines"]
+br_ibge_ipca15_mes_categoria_municipio.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca15_mes_categoria_municipio.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
@@ -61,7 +61,7 @@
 
 br_ibge_ipca15_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral)
 br_ibge_ipca15_mes_brasil.name = "br_ibge_ipca15.mes_brasil"
-br_ibge_ipca15_mes_brasil.code_owners = ["equipe_pipelines"]
+br_ibge_ipca15_mes_brasil.code_owners = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
 br_ibge_ipca15_mes_brasil.run_config = KubernetesRun(image=constants.DOCKER_IMAGE.value)
 br_ibge_ipca15_mes_brasil.schedule = schedule_br_ibge_ipca15_mes_brasil