Merge branch 'main' into staging/migra-captura-manual-gtfs

pipelines/migration/projeto_subsidio_sppo/CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog - projeto_subsidio_sppo
 
+## [1.0.1] - 2024-07-17
+
+### Alterado
+
+- Alterado o schedule do flow `SMTR: Subsídio SPPO Apuração - Tratamento` de 07:00 para 07:05 (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/106)
+
 ## [1.0.0] - 2024-06-28
 
 ### Alterado

pipelines/migration/projeto_subsidio_sppo/flows.py

@@ -43,7 +43,7 @@
     run_dbt_model,
 )
 from pipelines.migration.veiculo.flows import sppo_veiculo_dia
-from pipelines.schedules import every_day_hour_five, every_day_hour_seven
+from pipelines.schedules import every_day_hour_five, every_day_hour_seven_minute_five
 
 # EMD Imports #
 
@@ -268,4 +268,4 @@
     image=smtr_constants.DOCKER_IMAGE.value, labels=[smtr_constants.RJ_SMTR_AGENT_LABEL.value]
 )
 subsidio_sppo_apuracao.state_handlers = [handler_initialize_sentry, handler_inject_bd_credentials]
-subsidio_sppo_apuracao.schedule = every_day_hour_seven
+subsidio_sppo_apuracao.schedule = every_day_hour_seven_minute_five

pipelines/schedules.py

@@ -162,6 +162,18 @@ def generate_interval_schedule(
     ]
 )
 
+every_day_hour_seven_minute_five = Schedule(
+    clocks=[
+        IntervalClock(
+            interval=timedelta(days=1),
+            start_date=datetime(2022, 11, 30, 7, 5, tzinfo=timezone(constants.TIMEZONE.value)),
+            labels=[
+                emd_constants.RJ_SMTR_AGENT_LABEL.value,
+            ],
+        ),
+    ]
+)
+
 every_dayofmonth_one_and_sixteen = Schedule(
     clocks=[
         CronClock(