From f9de057911e3d69d04b3caa2877973e675d28318 Mon Sep 17 00:00:00 2001
From: lucas zanotelli <lucas@zanotelli.dev>
Date: Mon, 11 Dec 2023 16:27:46 -0300
Subject: [PATCH] testing datetime interval

---
 models/marts/enriched_history_operations.sql | 24 ++++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/models/marts/enriched_history_operations.sql b/models/marts/enriched_history_operations.sql
index 0648e38..1903046 100644
--- a/models/marts/enriched_history_operations.sql
+++ b/models/marts/enriched_history_operations.sql
@@ -33,11 +33,11 @@ with
             , batch_insert_ts
         from {{ ref('stg_history_ledgers') }}
          where
-            cast(batch_run_date as date) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 2 day)
-            and date(closed_at) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+            batch_run_date < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 60 minute)
+            and closed_at < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% if is_incremental() %}
-                and cast(batch_run_date as date) >= date('{{ dbt_airflow_macros.ds() }}') -- batch run is the min bound of a batch
-                and date(closed_at) >= date_sub(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+                and batch_run_date >= TIMESTAMP '{{ dbt_airflow_macros.ts() }}' -- batch run is the min bound of a batch
+                and closed_at >= date_sub(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% endif %}
     )
 
@@ -70,11 +70,11 @@ with
             , batch_insert_ts
         from {{ ref('stg_history_transactions') }}
         where
-            cast(batch_run_date as date) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 2 day)
-            and date(closed_at) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+            batch_run_date < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 60 minute)
+            and closed_at < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% if is_incremental() %}
-                and cast(batch_run_date as date) >= date('{{ dbt_airflow_macros.ds() }}') -- batch run is the min bound of a batch
-                and date(closed_at) >= date_sub(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+                and batch_run_date >= TIMESTAMP '{{ dbt_airflow_macros.ts() }}' -- batch run is the min bound of a batch
+                and closed_at >= date_sub(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% endif %}
     )
 
@@ -190,11 +190,11 @@ with
             , batch_insert_ts
         from {{ ref('stg_history_operations') }}
         where
-            cast(batch_run_date as date) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 2 day)
-            and date(closed_at) < date_add(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+            batch_run_date < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 60 minute)
+            and closed_at < date_add(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% if is_incremental() %}
-                and cast(batch_run_date as date) >= date('{{ dbt_airflow_macros.ds() }}') -- batch run is the min bound of a batch
-                and date(closed_at) >= date_sub(date('{{ dbt_airflow_macros.ds() }}'), interval 1 day)
+                and batch_run_date >= TIMESTAMP '{{ dbt_airflow_macros.ts() }}' -- batch run is the min bound of a batch
+                and closed_at >= date_sub(TIMESTAMP '{{ dbt_airflow_macros.ts() }}', interval 30 minute)
             {% endif %}
 
     )