Skip to content

Commit

Permalink
Altera schedule da apuração de 7:00 para 7:05 (#106)
Browse files Browse the repository at this point in the history
* altera echedule da apuração para 7:05

* atualiza changelog

* [pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

---------

Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
  • Loading branch information
3 people authored Jul 17, 2024
1 parent f9af081 commit e9184df
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 2 deletions.
6 changes: 6 additions & 0 deletions pipelines/migration/projeto_subsidio_sppo/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -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
Expand Down
4 changes: 2 additions & 2 deletions pipelines/migration/projeto_subsidio_sppo/flows.py
Original file line number Diff line number Diff line change
Expand Up @@ -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 #

Expand Down Expand Up @@ -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
12 changes: 12 additions & 0 deletions pipelines/schedules.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit e9184df

Please sign in to comment.