From 2cb35d063bc90f3277bb4029eca1f40690799c79 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Fri, 9 Aug 2024 10:46:14 -0400 Subject: [PATCH] lag to modified ts --- .../silver/core/silver__transactions_final.sql | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/models/silver/core/silver__transactions_final.sql b/models/silver/core/silver__transactions_final.sql index 68c8fa5..3555843 100644 --- a/models/silver/core/silver__transactions_final.sql +++ b/models/silver/core/silver__transactions_final.sql @@ -9,8 +9,20 @@ tags = ['core'] ) }} -WITH msg_atts AS ( +WITH MOD AS ( + SELECT + DATEADD( + HOUR, + -1, + MAX( + modified_timestamp + ) + ) modified_timestamp + FROM + {{ this }} +), +msg_atts AS ( SELECT tx_id, msg_index, @@ -27,7 +39,7 @@ WHERE modified_timestamp ) FROM - {{ this }} + MOD ) {% endif %} ), @@ -94,6 +106,6 @@ WHERE modified_timestamp ) FROM - {{ this }} + MOD ) {% endif %}