diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py b/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py index c2ee21164..21e13f05b 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/schedules.py @@ -27,9 +27,7 @@ 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=constants.BILHETAGEM_GENERAL_CAPTURE_PARAMS.value[ - "transacao_runs_interval_minutes" - ], + runs_interval_minutes=0, ) bilhetagem_transacao_schedule = Schedule(clocks=untuple(bilhetagem_transacao_clocks)) diff --git a/pipelines/rj_smtr/constants.py b/pipelines/rj_smtr/constants.py index ee8a22cd2..0037c6989 100644 --- a/pipelines/rj_smtr/constants.py +++ b/pipelines/rj_smtr/constants.py @@ -183,13 +183,11 @@ class constants(Enum): # pylint: disable=c0103 }, "vpn_url": "http://vpn-jae.mobilidade.rio/", "source_type": "api-json", - "transacao_runs_interval_minutes": 0, - "principal_runs_interval_minutes": 5, } BILHETAGEM_CAPTURE_RUN_INTERVAL = { "transacao_run_interval": {"minutes": 1}, - "principal_run_interval": {"days": 1}, + "principal_run_interval": {"hours": 1}, } BILHETAGEM_TRANSACAO_CAPTURE_PARAMS = { diff --git a/pipelines/rj_smtr/flows.py b/pipelines/rj_smtr/flows.py index 0efb69b17..d4292129c 100644 --- a/pipelines/rj_smtr/flows.py +++ b/pipelines/rj_smtr/flows.py @@ -140,8 +140,6 @@ flags = Parameter("flags", default=None) dbt_vars = Parameter("dbt_vars", default=dict()) - # treated_table_params = treat_dbt_table_params(table_params=table_params) - LABELS = get_current_flow_labels() MODE = get_current_flow_mode(LABELS)