Skip to content

Commit

Permalink
Migração - desativa schedules viagem zirix (#706)
Browse files Browse the repository at this point in the history
desativa schedules viagem zirix

Co-authored-by: Rafael Carvalho Pinheiro <[email protected]>
  • Loading branch information
akaBotelho and pixuimpou authored Jun 20, 2024
1 parent cc1552c commit 96667e1
Showing 1 changed file with 12 additions and 13 deletions.
25 changes: 12 additions & 13 deletions pipelines/rj_smtr/br_rj_riodejaneiro_viagem_zirix/flows.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand All @@ -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)
Expand All @@ -64,4 +63,4 @@
| {"recapture": True},
)

viagens_recaptura.schedule = every_hour
# viagens_recaptura.schedule = every_hour

0 comments on commit 96667e1

Please sign in to comment.