diff --git a/pipelines/br_rj_riodejaneiro_brt_gps/flows.py b/pipelines/br_rj_riodejaneiro_brt_gps/flows.py index 521e3c9a..b9ebf67a 100644 --- a/pipelines/br_rj_riodejaneiro_brt_gps/flows.py +++ b/pipelines/br_rj_riodejaneiro_brt_gps/flows.py @@ -26,6 +26,7 @@ pre_treatment_br_rj_riodejaneiro_brt_gps, ) from pipelines.constants import constants +from pipelines.schedules import every_hour, every_minute from pipelines.tasks import ( # get_local_dbt_client,; setup_task, bq_upload, create_date_hour_partition, @@ -46,8 +47,6 @@ upload_logs_to_bq, ) -# from pipelines.schedules import every_hour, every_minute - # Flows # with Flow( @@ -126,7 +125,7 @@ labels=[emd_constants.RJ_SMTR_DEV_AGENT_LABEL.value], ) materialize_brt.state_handlers = [handler_inject_bd_credentials] -# materialize_brt.schedule = every_hour +materialize_brt.schedule = every_hour with Flow( @@ -188,4 +187,4 @@ labels=[emd_constants.RJ_SMTR_DEV_AGENT_LABEL.value], ) captura_brt.state_handlers = [handler_inject_bd_credentials] -# captura_brt.schedule = every_minute +captura_brt.schedule = every_minute