From afb37d43091a883e488840dfcf085b95f5b694ae Mon Sep 17 00:00:00 2001 From: Rafael Date: Mon, 26 Aug 2024 18:40:15 -0300 Subject: [PATCH] Adiciona parametro truncate minutes --- pipelines/migration/br_rj_riodejaneiro_bilhetagem/constants.py | 1 + pipelines/migration/tasks.py | 1 + 2 files changed, 2 insertions(+) diff --git a/pipelines/migration/br_rj_riodejaneiro_bilhetagem/constants.py b/pipelines/migration/br_rj_riodejaneiro_bilhetagem/constants.py index 3392cf27..5d86f46a 100644 --- a/pipelines/migration/br_rj_riodejaneiro_bilhetagem/constants.py +++ b/pipelines/migration/br_rj_riodejaneiro_bilhetagem/constants.py @@ -549,6 +549,7 @@ class constants(Enum): # pylint: disable=c0103 "date_range": { "table_run_datetime_column_name": "data", "delay_hours": 0, + "truncate_minutes": False, }, "version": {}, }, diff --git a/pipelines/migration/tasks.py b/pipelines/migration/tasks.py index 94af2c10..ded988b9 100644 --- a/pipelines/migration/tasks.py +++ b/pipelines/migration/tasks.py @@ -237,6 +237,7 @@ def create_dbt_run_vars( mode=mode, delay_hours=dbt_vars["date_range"].get("delay_hours", 0), end_ts=timestamp, + truncate_minutes=dbt_vars["date_range"].get("truncate_minutes", True), ) flag_date_range = True