diff --git a/models/bronze/bronze__transactions_2.sql b/models/bronze/bronze__transactions_2.sql index dd5d559..77c5791 100644 --- a/models/bronze/bronze__transactions_2.sql +++ b/models/bronze/bronze__transactions_2.sql @@ -10,7 +10,10 @@ SELECT id, - VALUE :block_number :: INT AS block_id, + COALESCE( + VALUE :block_number, + VALUE: tx_responses :height + ) :: INT AS block_id, DATA :tx_responses :timestamp :: timestamp_ntz AS block_timestamp, DATA :tx_responses :codespace :: STRING AS codespace, DATA :tx_responses :gas_used :: INT AS gas_used, diff --git a/models/streamline/core/complete/streamline__complete_transactions.sql b/models/streamline/core/complete/streamline__complete_transactions.sql index df70cc8..bf2f7de 100644 --- a/models/streamline/core/complete/streamline__complete_transactions.sql +++ b/models/streamline/core/complete/streamline__complete_transactions.sql @@ -9,8 +9,11 @@ SELECT id, - block_number, - VALUE :metadata :request :params ['pagination.offset'] ::STRING AS pagination_offset, + COALESCE( + block_number, + VALUE: tx_responses :height + ) AS block_number, + VALUE :metadata :request :params ['pagination.offset'] :: STRING AS pagination_offset, _inserted_timestamp FROM @@ -29,4 +32,4 @@ WHERE qualify(ROW_NUMBER() over (PARTITION BY id, pagination_offset ORDER BY - _inserted_timestamp DESC)) = 1 \ No newline at end of file + _inserted_timestamp DESC)) = 1 diff --git a/models/streamline/core/realtime/streamline__transactions_realtime.sql b/models/streamline/core/realtime/streamline__transactions_realtime.sql index 1fa8650..379100a 100644 --- a/models/streamline/core/realtime/streamline__transactions_realtime.sql +++ b/models/streamline/core/realtime/streamline__transactions_realtime.sql @@ -17,7 +17,8 @@ WITH blocks AS ( b ON A.block_number = b.block_number WHERE - A.block_number = 12206934 + A.block_number > 11800000 + AND b.block_number IS NULL ), numbers AS ( -- Recursive CTE to generate numbers. We'll use the maximum txcount value to limit our recursion.