From afe68efddc9219238d12ecf4fa22f1c23f6c05bb Mon Sep 17 00:00:00 2001 From: Rafael Date: Tue, 30 Apr 2024 08:32:50 -0300 Subject: [PATCH] =?UTF-8?q?corrige=20defini=C3=A7=C3=A3o=20do=20daterange?= =?UTF-8?q?=20de=20rematerializa=C3=A7=C3=A3o?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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 3f732f265..2b7c90b73 100644 --- a/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py +++ b/pipelines/rj_smtr/br_rj_riodejaneiro_onibus_gps/flows.py @@ -187,10 +187,12 @@ name="assign_none_to_previous_runs", )() with case(rematerialization, True): - date_range_true = { - "date_range_start": date_range_start, - "date_range_end": date_range_end, - } + date_range_true = task( + lambda start, end: { + "date_range_start": start, + "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)