diff --git a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py index 2b7c90b73..bd649b506 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py @@ -193,6 +193,7 @@ "date_range_end": end, } )(start=date_range_start, end=date_range_end) + RUN_CLEAN_TRUE = clean_br_rj_riodejaneiro_onibus_gps(date_range_true) RUN_CLEAN = merge(RUN_CLEAN_TRUE, RUN_CLEAN_FALSE)