diff --git a/pipelines/migration/projeto_subsidio_sppo/CHANGELOG.md b/pipelines/migration/projeto_subsidio_sppo/CHANGELOG.md index bb86ddb4..c35d3682 100644 --- a/pipelines/migration/projeto_subsidio_sppo/CHANGELOG.md +++ b/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 diff --git a/pipelines/migration/projeto_subsidio_sppo/flows.py b/pipelines/migration/projeto_subsidio_sppo/flows.py index e65e27d9..0a9556c4 100644 --- a/pipelines/migration/projeto_subsidio_sppo/flows.py +++ b/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 diff --git a/pipelines/schedules.py b/pipelines/schedules.py index 8c6acf0a..e8921874 100644 --- a/pipelines/schedules.py +++ b/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(