reduce/dex-lookback (#522)

* reduce/dex-lookback

* inserted date filters

models/silver/defi/silver__complete_dex_swaps.sql

@@ -479,70 +479,6 @@ WHERE
     )
 {% endif %}
 ),
-
-{# osmosis AS (
-SELECT
-    'osmosis' AS blockchain,
-    'osmosis' platform,
-    s.block_id AS block_number,
-    s.block_timestamp,
-    s.tx_id AS tx_hash,
-    pool_address AS contract_address,
-    trader AS trader,
-    from_currency AS token_in,
-    NULL AS symbol_in,
-    from_amount AS amount_in_raw,
-    CASE
-        WHEN s.from_decimal IS NOT NULL THEN from_amount / power(
-            10,
-            s.from_decimal
-        )
-    END AS amount_in,
-    NULL AS amount_in_usd,
-    to_currency AS token_out,
-    NULL AS symbol_out,
-    to_amount AS amount_out_raw,
-    CASE
-        WHEN s.to_decimal IS NOT NULL THEN to_amount / power(
-            10,
-            s.to_decimal
-        )
-    END AS amount_out,
-    NULL AS amount_out_usd,
-    FALSE AS token_in_is_verified,
-    FALSE AS token_out_is_verified,
-    CONCAT(
-        s.tx_id,
-        '-',
-        s._BODY_INDEX
-    ) AS _log_id,
-    s.modified_timestamp AS _inserted_timestamp,
-    {{ dbt_utils.generate_surrogate_key(['fact_swaps_id','blockchain']) }} AS complete_dex_swaps_id,
-    {{ dbt_utils.generate_surrogate_key(['blockchain','block_number','platform']) }} AS _unique_key
-FROM
-    {{ source(
-        'osmosis_defi',
-        'fact_swaps'
-    ) }}
-    s
-    LEFT JOIN {{ source(
-        'osmosis_defi',
-        'dim_liquidity_pools'
-    ) }}
-    p
-    ON s.pool_id = p.pool_id
-
-{% if is_incremental() and 'osmosis' not in var('HEAL_MODELS') %}
-WHERE
-    _inserted_timestamp >= (
-        SELECT
-            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "24 hours") }}'
-        FROM
-            {{ this }}
-    )
-{% endif %}
-),
-#}
 solana AS (
     SELECT
         'solana' AS blockchain,
@@ -580,7 +516,7 @@ solana AS (
 WHERE
     _inserted_timestamp >= (
         SELECT
-            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "24 hours") }}'
+            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "6 hours") }}'
         FROM
             {{ this }}
     )
@@ -623,7 +559,7 @@ near AS (
 WHERE
     _inserted_timestamp >= (
         SELECT
-            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "24 hours") }}'
+            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "6 hours") }}'
         FROM
             {{ this }}
     )
@@ -666,7 +602,7 @@ aptos AS (
 WHERE
     _inserted_timestamp >= (
         SELECT
-            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "24 hours") }}'
+            MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "6 hours") }}'
         FROM
             {{ this }}
     )

models/streamline/silver/coingecko/prices/streamline__hourly_prices_coingecko_history.sql

@@ -19,7 +19,9 @@ WITH assets AS (
                 MAX(_inserted_timestamp)
             FROM
                 {{ ref('bronze__streamline_asset_metadata_coingecko') }}
+            WHERE _inserted_date >= DATEADD('day', -3, SYSDATE()) 
         )
+        AND _inserted_date >= DATEADD('day', -3, SYSDATE())
     --active tokens only
 ),
 run_times AS (

models/streamline/silver/coingecko/prices/streamline__hourly_prices_coingecko_realtime.sql

@@ -19,7 +19,9 @@ WITH assets AS (
                 MAX(_inserted_timestamp)
             FROM
                 {{ ref("bronze__streamline_asset_metadata_coingecko") }}
+            WHERE _inserted_date >= DATEADD('day', -3, SYSDATE()) 
         )
+        AND _inserted_date >= DATEADD('day', -3, SYSDATE())
 ),
 calls AS (
     SELECT

models/streamline/silver/coinmarketcap/prices/streamline__hourly_prices_coinmarketcap_realtime.sql

@@ -19,7 +19,9 @@ WITH assets AS (
                 MAX(_inserted_timestamp)
             FROM
                 {{ ref("bronze__streamline_asset_metadata_coinmarketcap") }}
+            WHERE _inserted_date >= DATEADD('day', -3, SYSDATE()) 
         )
+        AND _inserted_date >= DATEADD('day', -3, SYSDATE()) 
 ),
 run_times AS (
     SELECT