From 34d67f70d64ce73a7cff7250622ae88bd6e601f3 Mon Sep 17 00:00:00 2001
From: eric-laurello <102970824+eric-laurello@users.noreply.github.com>
Date: Mon, 6 Feb 2023 16:34:18 -0500
Subject: [PATCH] update streamline view driver (#98)

---
 .../silver/silver__all_unknown_pool_balances.sql   | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

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