diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py index 11082b761..43128cd17 100644 --- 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 index 9b6802e21..b0466b341 100644 --- 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 index 57c5aeb7a..f3fe247d5 100644 --- 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 index 557dce2a3..fc513e583 100644 --- 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