diff --git a/models/evm/streamline/silver/core/history/streamline__evm_traces_history.sql b/models/evm/streamline/silver/core/history/streamline__evm_traces_history.sql index cf95dd4..e60412a 100644 --- a/models/evm/streamline/silver/core/history/streamline__evm_traces_history.sql +++ b/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 \ No newline at end of file + limit 1000000 \ No newline at end of file diff --git a/models/evm/streamline/silver/core/realtime/streamline__evm_traces_realtime.sql b/models/evm/streamline/silver/core/realtime/streamline__evm_traces_realtime.sql index 0ef0799..e60f0e0 100644 --- a/models/evm/streamline/silver/core/realtime/streamline__evm_traces_realtime.sql +++ b/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 (