diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_gtfs/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_gtfs/flows.py index 9af776531..c7a95054a 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_gtfs/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_gtfs/flows.py @@ -66,10 +66,10 @@ LABELS = get_current_flow_labels() run_captura = create_flow_run.map( - flow_name=unmapped(gtfs_captura.name), - project_name=unmapped(constants_emd.PREFECT_DEFAULT_PROJECT.value), + flow_name=gtfs_captura.name, + project_name=constants_emd.PREFECT_DEFAULT_PROJECT.value, parameters=constants.GTFS_TABLE_CAPTURE_PARAMS.value, - labels=unmapped(LABELS), + labels=LABELS, ) wait_captura = wait_for_flow_run.map(