diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py index 1638817ef..9b28676da 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_bilhetagem/flows.py @@ -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 @@ -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),