traces

models/evm/streamline/silver/core/history/streamline__evm_traces_history.sql

@@ -4,8 +4,8 @@
         func = 'streamline.udf_bulk_rest_api_v2',
         target = "{{this.schema}}.{{this.identifier}}",
         params ={ "external_table" :"evm_traces",
-        "sql_limit" :"100000",
-        "producer_batch_size" :"10",
+        "sql_limit" :"1000000",
+        "producer_batch_size" :"100",
         "worker_batch_size" :"10",
         "sql_source" :"{{this.identifier}}",
         "exploded_key": tojson(["result"]) }
@@ -18,7 +18,11 @@ WITH to_do AS (
         block_number
     FROM
         {{ ref("streamline__evm_blocks") }}
-    WHERE block_number IS NOT NULL
+    WHERE block_number IS NOT NULL and block_number < (    
+        SELECT
+        block_number
+    FROM
+        {{ ref("_evm_block_lookback") }})
     EXCEPT
     SELECT
         block_number
@@ -60,4 +64,4 @@ FROM
     ready_blocks
         ORDER BY
             block_number asc
-    limit 100000
+    limit 1000000

models/evm/streamline/silver/core/realtime/streamline__evm_traces_realtime.sql

@@ -10,7 +10,7 @@
         "sql_source" :"{{this.identifier}}",
         "exploded_key": tojson(["result"]) }
     ),
-    tags = ['paused']
+    tags = ['streamline_core_evm_realtime']
 ) }}
 
 WITH last_3_days AS (