modify deepflow names

basedosdados · Nov 27, 2024 · b2cb75c · b2cb75c
1 parent 15bfe4a
commit b2cb75c
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 18 deletions.
diff --git a/pipelines/datasets/br_ibge_inpc/flows.py b/pipelines/datasets/br_ibge_inpc/flows.py
@@ -21,13 +21,13 @@
     schedule_br_ibge_inpc_mes_categoria_rm,
 )
 from pipelines.utils.crawler_ibge_inflacao.flows import (
-    flow_ibge_inflacao_mes_brasil,
+    flow_ibge_inflacao_mes_brasil_,
     flow_ibge_inflacao_mes_geral,
-    flow_ibge_inflacao_mes_municipio,
+    flow_ibge_inflacao_mes_municipio_,
     flow_ibge_inflacao_mes_rm,
 )
 
-br_ibge_inpc_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
+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 = ["Gabriel Pisa"]
 br_ibge_inpc_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
@@ -46,7 +46,7 @@
 )
 br_ibge_inpc_mes_categoria_rm.schedule = schedule_br_ibge_inpc_mes_categoria_rm
 
-br_ibge_inpc_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
+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 = ["Gabriel Pisa"]
 br_ibge_inpc_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)

diff --git a/pipelines/datasets/br_ibge_ipca/flows.py b/pipelines/datasets/br_ibge_ipca/flows.py
@@ -17,13 +17,13 @@
     schedule_br_ibge_ipca_mes_categoria_rm,
 )
 from pipelines.utils.crawler_ibge_inflacao.flows import (
-    flow_ibge_inflacao_mes_brasil,
+    flow_ibge_inflacao_mes_brasil_,
     flow_ibge_inflacao_mes_geral,
-    flow_ibge_inflacao_mes_municipio,
+    flow_ibge_inflacao_mes_municipio_,
     flow_ibge_inflacao_mes_rm,
 )
 
-br_ibge_ipca_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
+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 = ["Gabriel Pisa"]
 br_ibge_ipca_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
@@ -42,7 +42,7 @@
 )
 br_ibge_ipca_mes_categoria_rm.schedule = schedule_br_ibge_ipca_mes_categoria_rm
 
-br_ibge_ipca_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
+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 = ["Gabriel Pisa"]
 br_ibge_ipca_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)

diff --git a/pipelines/datasets/br_ibge_ipca15/flows.py b/pipelines/datasets/br_ibge_ipca15/flows.py
@@ -21,13 +21,13 @@
     schedule_br_ibge_ipca15_mes_categoria_rm,
 )
 from pipelines.utils.crawler_ibge_inflacao.flows import (
-    flow_ibge_inflacao_mes_brasil,
+    flow_ibge_inflacao_mes_brasil_,
     flow_ibge_inflacao_mes_geral,
-    flow_ibge_inflacao_mes_municipio,
+    flow_ibge_inflacao_mes_municipio_,
     flow_ibge_inflacao_mes_rm,
 )
 
-br_ibge_ipca15_mes_categoria_brasil = deepcopy(flow_ibge_inflacao_mes_brasil)
+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 = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_categoria_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
@@ -47,7 +47,7 @@
 )
 br_ibge_ipca15_mes_categoria_rm.schedule = schedule_br_ibge_ipca15_mes_categoria_rm
 
-br_ibge_ipca15_mes_categoria_municipio = deepcopy(flow_ibge_inflacao_mes_municipio)
+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 = ["Gabriel Pisa"]
 br_ibge_ipca15_mes_categoria_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)

diff --git a/pipelines/utils/crawler_ibge_inflacao/flows.py b/pipelines/utils/crawler_ibge_inflacao/flows.py
@@ -31,7 +31,7 @@
 
 with Flow(
     name="BD Template - IBGE Inflação: mes_brasil"
-) as flow_ibge_inflacao_mes_brasil:
+) as flow_ibge_inflacao_mes_brasil_:
     INDICE = Parameter("indice")
     FOLDER = Parameter("folder")
     dataset_id = Parameter("dataset_id")
@@ -112,8 +112,8 @@
             )
 
 
-flow_ibge_inflacao_mes_brasil.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
-flow_ibge_inflacao_mes_brasil.run_config = KubernetesRun(
+flow_ibge_inflacao_mes_brasil_.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
+flow_ibge_inflacao_mes_brasil_.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
 )
 
@@ -205,7 +205,7 @@
 
 with Flow(
     "BD Template - IBGE Inflação: mes_municipio"
-) as flow_ibge_inflacao_mes_municipio:
+) as flow_ibge_inflacao_mes_municipio_:
     # Parameters
     INDICE = Parameter("indice")
     FOLDER = Parameter("folder")
@@ -287,8 +287,8 @@
             )
 
 
-flow_ibge_inflacao_mes_municipio.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
-flow_ibge_inflacao_mes_municipio.run_config = KubernetesRun(
+flow_ibge_inflacao_mes_municipio_.storage = GCS(constants.GCS_FLOWS_BUCKET.value)
+flow_ibge_inflacao_mes_municipio_.run_config = KubernetesRun(
     image=constants.DOCKER_IMAGE.value
 )