Merge pull request #357 from FlipsideCrypto/AN-5269-fix-xfers-price

token transfers - price filter in incr block

models/gold/core/core__ez_token_transfers.sql

@@ -17,11 +17,26 @@ WITH hourly_prices AS (
         modified_timestamp
     FROM
         {{ ref('price__ez_prices_hourly') }}
-    WHERE
-        HOUR >= DATEADD(DAY, -1, SYSDATE())
-    QUALIFY(ROW_NUMBER() OVER (PARTITION BY token_address, HOUR
-    ORDER BY
-        HOUR DESC) = 1)
+
+        {% if var('MANUAL_FIX') %}
+        -- Note, this will intentionally fail if a date range is not passed
+        WHERE
+            DATE_TRUNC(
+                'day',
+                HOUR
+            ) BETWEEN '{{ var('RANGE_START_DATE', None) }}'
+            AND '{{ var('RANGE_END_DATE', None) }}'
+        {% else %}
+
+{% if is_incremental() %}
+WHERE
+    HOUR >= DATEADD(DAY, -1, SYSDATE())
+{% endif %}
+{% endif %}
+
+qualify(ROW_NUMBER() over (PARTITION BY token_address, HOUR
+ORDER BY
+    HOUR DESC) = 1)
 )
 SELECT
     block_id,
@@ -65,25 +80,28 @@ FROM
         'hour',
         t.block_timestamp
     ) = HOUR
-    LEFT JOIN {{ ref('silver__ft_contract_metadata') }} C USING (contract_address)
-{% if var("MANUAL_FIX") %}
-    WHERE {{ partition_load_manual('no_buffer') }}
-{% else %}
-    {% if is_incremental() %}
+    LEFT JOIN {{ ref('silver__ft_contract_metadata') }} C USING (contract_address) 
+    
+    {% if var("MANUAL_FIX") %}
     WHERE
-        GREATEST(
-            t.modified_timestamp,
+        {{ partition_load_manual('no_buffer') }}
+    {% else %}
+
+        {% if is_incremental() %}
+        WHERE
+            GREATEST(
+                t.modified_timestamp,
                 '2000-01-01'
-        ) >= DATEADD(
-            'minute',
-            -5,(
-                SELECT
-                    MAX(
-                        modified_timestamp
-                    )
-                FROM
-                    {{ this }}
+            ) >= DATEADD(
+                'minute',
+                -5,(
+                    SELECT
+                        MAX(
+                            modified_timestamp
+                        )
+                    FROM
+                        {{ this }}
+                )
             )
-        )
+        {% endif %}
     {% endif %}
-{% endif %}