[HOTFIX] Alterar constante materialização ordem pagamento validação /…

… corrigir verificação de tipo daterange materialização (#555) * alterar nome da coluna date * corrigir bug date_range
prefeitura-rio · Nov 9, 2023 · 11b8878 · 11b8878
1 parent ae01c67
commit 11b8878
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pipelines/rj_smtr/constants.py b/pipelines/rj_smtr/constants.py
@@ -440,7 +440,7 @@ class constants(Enum):  # pylint: disable=c0103
         "exclude": f"+{BILHETAGEM_MATERIALIZACAO_TRANSACAO_PARAMS['table_id']}",
         "dbt_vars": {
             "date_range": {
-                "table_run_datetime_column_name": "data",
+                "table_run_datetime_column_name": "data_ordem",
                 "delay_hours": 0,
             },
             "version": {},

diff --git a/pipelines/rj_smtr/tasks.py b/pipelines/rj_smtr/tasks.py
@@ -1088,7 +1088,7 @@ def get_materialization_date_range(  # pylint: disable=R0913
     else:
         last_run = datetime.strptime(last_run, timestr)
 
-    if isinstance(last_run, date):
+    if (not isinstance(last_run, datetime)) and (isinstance(last_run, date)):
         last_run = datetime(last_run.year, last_run.month, last_run.day)
 
     # set start to last run hour (H)