From 30a2df60ba1e8c9c910cf341527774991d87e8b7 Mon Sep 17 00:00:00 2001 From: Laura Amaral Date: Tue, 2 Jan 2024 14:20:41 -0300 Subject: [PATCH 1/3] fix: schedules --- pipelines/datasets/br_ibge_inpc/flows.py | 4 +--- pipelines/datasets/br_ibge_ipca15/flows.py | 8 ++------ 2 files changed, 3 insertions(+), 9 deletions(-) diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py index 280a4622d..c4ca722b0 100644 --- a/pipelines/datasets/br_ibge_inpc/flows.py +++ b/pipelines/datasets/br_ibge_inpc/flows.py @@ -49,9 +49,7 @@ br_ibge_inpc_mes_categoria_municipio.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_inpc_mes_categoria_municipio.schedule = ( - schedule_br_ibge_inpc_mes_categoria_municipio -) +br_ibge_inpc_mes_categoria_municipio.schedule = schedule_br_ibge_inpc_mes_categoria_municipio br_ibge_inpc_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral) br_ibge_inpc_mes_brasil.name = "br_ibge_inpc.mes_brasil" diff --git a/pipelines/datasets/br_ibge_ipca15/flows.py b/pipelines/datasets/br_ibge_ipca15/flows.py index cb8228110..f29047d58 100644 --- a/pipelines/datasets/br_ibge_ipca15/flows.py +++ b/pipelines/datasets/br_ibge_ipca15/flows.py @@ -30,9 +30,7 @@ br_ibge_ipca15_mes_categoria_brasil.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_ipca15_mes_categoria_brasil.schedule = ( - schedule_br_ibge_ipca15_mes_categoria_brasil -) +br_ibge_ipca15_mes_categoria_brasil.schedule = schedule_br_ibge_ipca15_mes_categoria_brasil br_ibge_ipca15_mes_categoria_rm = deepcopy(flow_ibge_inflacao_mes_rm) @@ -51,9 +49,7 @@ br_ibge_ipca15_mes_categoria_municipio.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_ipca15_mes_categoria_municipio.schedule = ( - schedule_br_ibge_ipca15_mes_categoria_municipio -) +br_ibge_ipca15_mes_categoria_municipio.schedule = schedule_br_ibge_ipca15_mes_categoria_municipio br_ibge_ipca15_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral) br_ibge_ipca15_mes_brasil.name = "br_ibge_ipca15.mes_brasil" From 1e5451ad966eac9a388cbb68150278c9103d8ebb Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Tue, 2 Jan 2024 17:22:32 +0000 Subject: [PATCH 2/3] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- pipelines/datasets/br_ibge_inpc/flows.py | 4 +++- pipelines/datasets/br_ibge_ipca15/flows.py | 8 ++++++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py index c4ca722b0..280a4622d 100644 --- a/pipelines/datasets/br_ibge_inpc/flows.py +++ b/pipelines/datasets/br_ibge_inpc/flows.py @@ -49,7 +49,9 @@ br_ibge_inpc_mes_categoria_municipio.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_inpc_mes_categoria_municipio.schedule = schedule_br_ibge_inpc_mes_categoria_municipio +br_ibge_inpc_mes_categoria_municipio.schedule = ( + schedule_br_ibge_inpc_mes_categoria_municipio +) br_ibge_inpc_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral) br_ibge_inpc_mes_brasil.name = "br_ibge_inpc.mes_brasil" diff --git a/pipelines/datasets/br_ibge_ipca15/flows.py b/pipelines/datasets/br_ibge_ipca15/flows.py index f29047d58..cb8228110 100644 --- a/pipelines/datasets/br_ibge_ipca15/flows.py +++ b/pipelines/datasets/br_ibge_ipca15/flows.py @@ -30,7 +30,9 @@ br_ibge_ipca15_mes_categoria_brasil.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_ipca15_mes_categoria_brasil.schedule = schedule_br_ibge_ipca15_mes_categoria_brasil +br_ibge_ipca15_mes_categoria_brasil.schedule = ( + schedule_br_ibge_ipca15_mes_categoria_brasil +) br_ibge_ipca15_mes_categoria_rm = deepcopy(flow_ibge_inflacao_mes_rm) @@ -49,7 +51,9 @@ br_ibge_ipca15_mes_categoria_municipio.run_config = KubernetesRun( image=constants.DOCKER_IMAGE.value ) -br_ibge_ipca15_mes_categoria_municipio.schedule = schedule_br_ibge_ipca15_mes_categoria_municipio +br_ibge_ipca15_mes_categoria_municipio.schedule = ( + schedule_br_ibge_ipca15_mes_categoria_municipio +) br_ibge_ipca15_mes_brasil = deepcopy(flow_ibge_inflacao_mes_geral) br_ibge_ipca15_mes_brasil.name = "br_ibge_ipca15.mes_brasil" From f5345d1e466bc2fee318ac2e32a325abf7aa7ec2 Mon Sep 17 00:00:00 2001 From: Laura Amaral Date: Wed, 3 Jan 2024 11:44:25 -0300 Subject: [PATCH 3/3] changes to re register on prefect --- pipelines/datasets/br_ibge_inpc/flows.py | 4 ++++ pipelines/datasets/br_ibge_inpc/schedules.py | 4 ++++ pipelines/datasets/br_ibge_ipca15/flows.py | 4 ++++ pipelines/datasets/br_ibge_ipca15/schedules.py | 4 ++++ 4 files changed, 16 insertions(+) diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py index c4ca722b0..880d64fba 100644 --- a/pipelines/datasets/br_ibge_inpc/flows.py +++ b/pipelines/datasets/br_ibge_inpc/flows.py @@ -1,6 +1,10 @@ # -*- coding: utf-8 -*- """ Flows for br_ibge_inpc + - mes_categoria_brasil + - mes_categoria_rm + - mes_categoria_municipio + - mes_brasil """ # pylint: disable=C0103, E1123, invalid-name diff --git a/pipelines/datasets/br_ibge_inpc/schedules.py b/pipelines/datasets/br_ibge_inpc/schedules.py index 1980981a4..9b6802e21 100644 --- a/pipelines/datasets/br_ibge_inpc/schedules.py +++ b/pipelines/datasets/br_ibge_inpc/schedules.py @@ -1,6 +1,10 @@ # -*- coding: utf-8 -*- """ Schedules for br_ibge_inpc + - mes_categoria_brasil + - mes_categoria_rm + - mes_categoria_municipio + - mes_brasil """ from datetime import datetime diff --git a/pipelines/datasets/br_ibge_ipca15/flows.py b/pipelines/datasets/br_ibge_ipca15/flows.py index f29047d58..0aeac061e 100644 --- a/pipelines/datasets/br_ibge_ipca15/flows.py +++ b/pipelines/datasets/br_ibge_ipca15/flows.py @@ -1,6 +1,10 @@ # -*- coding: utf-8 -*- """ Flows for br_ibge_ipca15 + - mes_categoria_brasil + - mes_categoria_rm + - mes_categoria_municipio + - mes_brasil """ # pylint: disable=C0103, E1123, invalid-name diff --git a/pipelines/datasets/br_ibge_ipca15/schedules.py b/pipelines/datasets/br_ibge_ipca15/schedules.py index c73d96d33..f0430e2f8 100644 --- a/pipelines/datasets/br_ibge_ipca15/schedules.py +++ b/pipelines/datasets/br_ibge_ipca15/schedules.py @@ -1,6 +1,10 @@ # -*- coding: utf-8 -*- """ Schedules for br_ibge_ipca15 + - mes_categoria_brasil + - mes_categoria_rm + - mes_categoria_municipio + - mes_brasil """ from datetime import datetime