diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps_zirix/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps_zirix/flows.py index 3521d2d9e..46d47e59f 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps_zirix/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps_zirix/flows.py @@ -124,7 +124,7 @@ image=emd_constants.DOCKER_IMAGE.value, labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value], ) -realocacao_sppo_zirix.schedule = every_10_minutes +# realocacao_sppo_zirix.schedule = every_10_minutes with Flow( @@ -273,7 +273,7 @@ image=emd_constants.DOCKER_IMAGE.value, labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value], ) -captura_sppo_zirix.schedule = every_minute +# captura_sppo_zirix.schedule = every_minute with Flow( @@ -379,4 +379,4 @@ image=emd_constants.DOCKER_IMAGE.value, labels=[emd_constants.RJ_SMTR_AGENT_LABEL.value], ) -recaptura_zirix.schedule = every_hour_minute_six +# recaptura_zirix.schedule = every_hour_minute_six diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py index 78769da39..2d61faa03 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_recursos/flows.py @@ -27,7 +27,8 @@ from pipelines.rj_smtr.tasks import get_current_timestamp from pipelines.rj_smtr.flows import default_capture_flow, default_materialization_flow -from pipelines.rj_smtr.schedules import every_day + +# from pipelines.rj_smtr.schedules import every_day # CAPTURA DOS TICKETS # @@ -106,9 +107,11 @@ ] table_params = task( - lambda tables, exclude: [t for t in tables if t["table_id"] not in exclude] - if exclude is not None - else tables, + lambda tables, exclude: ( + [t for t in tables if t["table_id"] not in exclude] + if exclude is not None + else tables + ), checkpoint=False, name="get_tables_to_run", )(tables=constants.SUBSIDIO_SPPO_RECURSOS_TABLE_IDS.value, exclude=exclude) @@ -197,4 +200,4 @@ ) # Schedule -subsidio_sppo_recurso.schedule = every_day +# subsidio_sppo_recurso.schedule = every_day diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_viagem_zirix/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_viagem_zirix/flows.py index 5be2cd5c9..1a0b3177f 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_viagem_zirix/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_viagem_zirix/flows.py @@ -7,28 +7,27 @@ from prefect.run_configs import KubernetesRun from prefect.storage import GCS +from pipelines.constants import constants as emd_constants +from pipelines.rj_smtr.br_rj_riodejaneiro_viagem_zirix.constants import ( + constants as zirix_constants, +) +from pipelines.rj_smtr.flows import default_capture_flow + +# from pipelines.utils.decorators import Flow +from pipelines.utils.utils import set_default_parameters + # from prefect.tasks.prefect import create_flow_run, wait_for_flow_run # EMD Imports # -from pipelines.constants import constants as emd_constants - -from pipelines.utils.decorators import Flow -from pipelines.utils.utils import set_default_parameters # from pipelines.utils.execute_dbt_model.tasks import get_k8s_dbt_client # SMTR Imports # -from pipelines.rj_smtr.flows import default_capture_flow - - -from pipelines.rj_smtr.br_rj_riodejaneiro_viagem_zirix.constants import ( - constants as zirix_constants, -) -from pipelines.rj_smtr.schedules import every_10_minutes, every_hour +# from pipelines.rj_smtr.schedules import every_10_minutes, every_hour # from pipelines.utils.execute_dbt_model.tasks import run_dbt_model @@ -47,7 +46,7 @@ default_parameters=zirix_constants.VIAGEM_CAPTURE_PARAMETERS.value, ) -viagens_captura.schedule = every_10_minutes +# viagens_captura.schedule = every_10_minutes viagens_recaptura = deepcopy(default_capture_flow) @@ -64,4 +63,4 @@ | {"recapture": True}, ) -viagens_recaptura.schedule = every_hour +# viagens_recaptura.schedule = every_hour