From 0ffb8c51e2f7670a2e669a4719b49fde84ff2dd3 Mon Sep 17 00:00:00 2001 From: Rafael Carvalho Pinheiro <74972217+pixuimpou@users.noreply.github.com> Date: Mon, 19 Aug 2024 16:02:48 -0300 Subject: [PATCH] corrige task get_materialization_date_range (#148) --- pipelines/migration/tasks.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pipelines/migration/tasks.py b/pipelines/migration/tasks.py index b7c2d84e..94af2c10 100644 --- a/pipelines/migration/tasks.py +++ b/pipelines/migration/tasks.py @@ -1324,10 +1324,12 @@ def get_materialization_date_range( # pylint: disable=R0913 last_run = datetime(last_run.year, last_run.month, last_run.day) # set start to last run hour (H) - start_ts = last_run.replace(second=0, microsecond=0).strftime(timestr) + start_ts = last_run.replace(second=0, microsecond=0) if truncate_minutes: start_ts = start_ts.replace(minute=0) + start_ts = start_ts.strftime(timestr) + # set end to now - delay if not end_ts: