diff --git a/models/silver/silver__all_unknown_pool_balances.sql b/models/silver/silver__all_unknown_pool_balances.sql index aa1e99c..c7dc833 100644 --- a/models/silver/silver__all_unknown_pool_balances.sql +++ b/models/silver/silver__all_unknown_pool_balances.sql @@ -3,23 +3,25 @@ post_hook = 'call silver.sp_bulk_get_pool_balances()', ) }} -WITH last_block_of_date AS ( +WITH last_block_of_hour AS ( SELECT - block_timestamp :: DATE, + DATE_TRUNC( + 'hour', + block_timestamp + ) AS block_hour, MAX(block_id) AS block_id FROM {{ ref('silver__blocks') }} WHERE - block_id >= 2300000 - AND block_timestamp :: DATE <= CURRENT_DATE - 1 + block_id >= 2300000 {# AND block_timestamp :: DATE <= CURRENT_DATE - 1 #} GROUP BY 1 ) SELECT block_id FROM - last_block_of_date + last_block_of_hour UNION SELECT 2300000 -- origin block of data available from api @@ -31,3 +33,5 @@ FROM 'bronze_streamline', 'pool_balances_api' ) }} +ORDER BY + block_id DESC