From 0bf3ade6cc89ebc1714421ecb3207524dd969cbb Mon Sep 17 00:00:00 2001 From: Rafael Date: Tue, 17 Oct 2023 14:34:01 -0300 Subject: [PATCH] remove arquivo de schedules da bilhetagem --- .../schedules.py | 33 ------------------- 1 file changed, 33 deletions(-) delete mode 100644 pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py b/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py deleted file mode 100644 index 6cb4b0724..000000000 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py +++ /dev/null @@ -1,33 +0,0 @@ -# -*- coding: utf-8 -*- -""" -Schedules for br_rj_riodejaneiro_bilhetagem -""" - -from datetime import timedelta - -from prefect.schedules import Schedule - -from pipelines.constants import constants as emd_constants -from pipelines.utils.utils import untuple_clocks as untuple - -from pipelines.rj_smtr.constants import constants -from pipelines.rj_smtr.utils import ( - generate_execute_schedules, -) - -BILHETAGEM_TRANSACAO_INTERVAL = timedelta(minutes=1) -bilhetagem_transacao_clocks = generate_execute_schedules( - clock_interval=timedelta( - **constants.BILHETAGEM_CAPTURE_RUN_INTERVAL.value["transacao_run_interval"] - ), - labels=[ - emd_constants.RJ_SMTR_DEV_AGENT_LABEL.value, - ], - table_parameters=constants.BILHETAGEM_TRANSACAO_CAPTURE_PARAMS.value, - dataset_id=constants.BILHETAGEM_DATASET_ID.value, - secret_path=constants.BILHETAGEM_SECRET_PATH.value, - source_type=constants.BILHETAGEM_GENERAL_CAPTURE_PARAMS.value["source_type"], - runs_interval_minutes=0, -) - -bilhetagem_transacao_schedule = Schedule(clocks=untuple(bilhetagem_transacao_clocks))