Merge branch 'staging/add-captura-retorno-cct' of https://github.com/…

…prefeitura-rio/pipelines into staging/add-captura-retorno-cct
prefeitura-rio · Jun 3, 2024 · 175a6f0 · 175a6f0
2 parents a7afb3d + c053cc1
commit 175a6f0
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py
@@ -52,11 +52,11 @@
     clean_br_rj_riodejaneiro_onibus_gps,
 )
 
-from pipelines.rj_smtr.schedules import (
-    every_hour_minute_six,
-    every_minute,
-    every_10_minutes,
-)
+# from pipelines.rj_smtr.schedules import (
+#     every_hour_minute_six,
+#     every_minute,
+#     every_10_minutes,
+# )
 from pipelines.utils.execute_dbt_model.tasks import run_dbt_model
 from pipelines.utils.utils import skip_if_running_handler
 
@@ -135,7 +135,7 @@
     image=emd_constants.DOCKER_IMAGE.value,
     labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value],
 )
-realocacao_sppo.schedule = every_10_minutes
+# realocacao_sppo.schedule = every_10_minutes
 
 
 with Flow(
@@ -317,7 +317,7 @@
     image=emd_constants.DOCKER_IMAGE.value,
     labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value],
 )
-captura_sppo_v2.schedule = every_minute
+# captura_sppo_v2.schedule = every_minute
 
 with Flow(
     "SMTR: GPS SPPO Realocação - Recaptura (subflow)",
@@ -528,4 +528,4 @@
 
 recaptura.state_handlers.append(skip_if_running_handler)
 
-recaptura.schedule = every_hour_minute_six
+# recaptura.schedule = every_hour_minute_six