Skip to content

Commit

Permalink
teste log
Browse files Browse the repository at this point in the history
  • Loading branch information
pixuimpou committed Oct 18, 2023
1 parent e75e7a6 commit 6b6d0cb
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,9 @@
from prefect.utilities.edges import unmapped
from prefect import Parameter

from prefect import task
from pipelines.utils.utils import log

# EMD Imports #

from pipelines.constants import constants as emd_constants
Expand Down Expand Up @@ -151,6 +154,8 @@
},
)

task(lambda x: log(x))(x=recaptura_auxiliar_params)

runs_recaptura_auxiliar = create_flow_run.map(
flow_name=unmapped(bilhetagem_auxiliar_captura.name),
# project_name=unmapped(emd_constants.PREFECT_DEFAULT_PROJECT.value),
Expand Down

0 comments on commit 6b6d0cb

Please sign in to comment.