diff --git a/models/gold/core/core__ez_native_transfers.sql b/models/gold/core/core__ez_native_transfers.sql index 6f22840..f0a4c6d 100644 --- a/models/gold/core/core__ez_native_transfers.sql +++ b/models/gold/core/core__ez_native_transfers.sql @@ -13,7 +13,6 @@ SELECT block_timestamp, tx_position, trace_index, - identifier, --deprecate trace_address, --new column origin_from_address, origin_to_address, @@ -26,12 +25,13 @@ SELECT amount_usd, native_transfers_id AS ez_native_transfers_id, SYSDATE() AS inserted_timestamp, - SYSDATE() AS modified_timestamp + SYSDATE() AS modified_timestamp, + identifier --deprecate FROM {{ ref('silver__native_transfers') }} {% if is_incremental() %} -AND modified_timestamp > ( +WHERE modified_timestamp > ( SELECT COALESCE(MAX(modified_timestamp), '1970-01-01' :: TIMESTAMP) AS modified_timestamp FROM diff --git a/models/gold/core/core__fact_traces.sql b/models/gold/core/core__fact_traces.sql index 1447823..da80672 100644 --- a/models/gold/core/core__fact_traces.sql +++ b/models/gold/core/core__fact_traces.sql @@ -471,10 +471,10 @@ SELECT error_reason, revert_reason, tx_succeeded, - identifier, - DATA, - tx_status, - trace_status, + identifier, --deprecate + DATA, --deprecate + tx_status, --deprecate + trace_status, --deprecate {{ dbt_utils.generate_surrogate_key( ['tx_hash', 'trace_index'] ) }} AS fact_traces_id, diff --git a/models/silver/defi/bridge/across/silver_bridge__across_v3fundsdeposited.sql b/models/silver/defi/bridge/across/silver_bridge__across_v3fundsdeposited.sql index a950e6c..8be07d3 100644 --- a/models/silver/defi/bridge/across/silver_bridge__across_v3fundsdeposited.sql +++ b/models/silver/defi/bridge/across/silver_bridge__across_v3fundsdeposited.sql @@ -49,10 +49,7 @@ WITH base_evt AS ( CONCAT('0x', SUBSTR(segmented_data [7] :: STRING, 25, 40)) AS recipient, CONCAT('0x', SUBSTR(segmented_data [8] :: STRING, 25, 40)) AS exclusiveRelayer, segmented_data [9] :: STRING AS message, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/bridge/axelar/silver_bridge__axelar_contractcallwithtoken.sql b/models/silver/defi/bridge/axelar/silver_bridge__axelar_contractcallwithtoken.sql index f1aac83..446960e 100644 --- a/models/silver/defi/bridge/axelar/silver_bridge__axelar_contractcallwithtoken.sql +++ b/models/silver/defi/bridge/axelar/silver_bridge__axelar_contractcallwithtoken.sql @@ -35,10 +35,7 @@ WITH base_evt AS ( decoded_log :"symbol" :: STRING AS symbol, decoded_log, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -92,10 +89,7 @@ native_gas_paid AS ( decoded_log :"symbol" :: STRING AS symbol, decoded_log, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/bridge/hyperlane/silver_bridge__hyperlane_bridge.sql b/models/silver/defi/bridge/hyperlane/silver_bridge__hyperlane_bridge.sql index b54fef4..a04905d 100644 --- a/models/silver/defi/bridge/hyperlane/silver_bridge__hyperlane_bridge.sql +++ b/models/silver/defi/bridge/hyperlane/silver_bridge__hyperlane_bridge.sql @@ -24,10 +24,7 @@ WITH dispatch AS ( CONCAT('0x', SUBSTR(topics [3] :: STRING, 27, 40)) AS dst_bridge_token, -- dst bridge token address, not recipient address DATA, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -58,10 +55,7 @@ dispatch_id AS ( tx_hash, event_index, topics [1] :: STRING AS messageId, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -96,10 +90,7 @@ gas_payment AS ( regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data, TRY_TO_NUMBER(utils.udf_hex_to_int(segmented_data [0] :: STRING)) AS gasAmount, TRY_TO_NUMBER(utils.udf_hex_to_int(segmented_data [1] :: STRING)) AS payment, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -133,10 +124,7 @@ sent_transfer_remote AS ( CONCAT('0x', SUBSTR(topics [2] :: STRING, 27, 40)) AS recipient, -- actual recipient TRY_TO_NUMBER(utils.udf_hex_to_int(DATA :: STRING)) AS amount, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/bridge/layerzero/silver_bridge__layerzero_bridge_v2.sql b/models/silver/defi/bridge/layerzero/silver_bridge__layerzero_bridge_v2.sql index 250e766..5105bbc 100644 --- a/models/silver/defi/bridge/layerzero/silver_bridge__layerzero_bridge_v2.sql +++ b/models/silver/defi/bridge/layerzero/silver_bridge__layerzero_bridge_v2.sql @@ -13,14 +13,8 @@ WITH oft_asset_contract_creation AS ( block_timestamp, tx_hash, from_address AS oft_address, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + tx_succeeded, + trace_succeeded, modified_timestamp FROM {{ ref('core__fact_traces') }} @@ -57,14 +51,8 @@ oft_asset_base_token AS ( tx_hash, from_address AS wrap_address, to_address AS underlying_address, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + tx_succeeded, + trace_succeeded, modified_timestamp FROM {{ ref('core__fact_traces') }} diff --git a/models/silver/defi/bridge/symbiosis/silver_bridge__symbiosis_synthesizerequest.sql b/models/silver/defi/bridge/symbiosis/silver_bridge__symbiosis_synthesizerequest.sql index a45c7b0..eca6dea 100644 --- a/models/silver/defi/bridge/symbiosis/silver_bridge__symbiosis_synthesizerequest.sql +++ b/models/silver/defi/bridge/symbiosis/silver_bridge__symbiosis_synthesizerequest.sql @@ -36,10 +36,7 @@ WITH base_evt AS ( CONCAT('0x', SUBSTR(topics [3] :: STRING, 27, 40)) AS revertableAddress, CONCAT('0x', SUBSTR(segmented_data [1] :: STRING, 25, 40)) AS to_address, CONCAT('0x', SUBSTR(segmented_data [3] :: STRING, 25, 40)) AS token, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/bridge/synapse/silver_bridge__synapse_tokenredeem.sql b/models/silver/defi/bridge/synapse/silver_bridge__synapse_tokenredeem.sql index 65aa6d4..ef54be4 100644 --- a/models/silver/defi/bridge/synapse/silver_bridge__synapse_tokenredeem.sql +++ b/models/silver/defi/bridge/synapse/silver_bridge__synapse_tokenredeem.sql @@ -24,10 +24,7 @@ WITH base_evt AS ( topics [3] :: STRING AS topic_3, DATA, regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/dex/fenix/silver_dex__fenix_swaps_v3.sql b/models/silver/defi/dex/fenix/silver_dex__fenix_swaps_v3.sql index b2261d6..7087719 100644 --- a/models/silver/defi/dex/fenix/silver_dex__fenix_swaps_v3.sql +++ b/models/silver/defi/dex/fenix/silver_dex__fenix_swaps_v3.sql @@ -71,7 +71,7 @@ AND l.modified_timestamp >= ( FROM {{ this }} ) -AND l._inserted_timestamp >= SYSDATE() - INTERVAL '7 day' +AND l.modified_timestamp >= SYSDATE() - INTERVAL '7 day' {% endif %} ) SELECT diff --git a/models/silver/defi/lending/init/silver__init_asset_details.sql b/models/silver/defi/lending/init/silver__init_asset_details.sql index 347380d..6d1d41b 100644 --- a/models/silver/defi/lending/init/silver__init_asset_details.sql +++ b/models/silver/defi/lending/init/silver__init_asset_details.sql @@ -44,10 +44,7 @@ underlying AS ( tx_hash, block_timestamp, block_number, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, from_address AS token_address, to_address AS underlying_asset_address FROM @@ -74,10 +71,7 @@ unwrapped AS ( SELECT from_address AS underlying_asset_address, to_address AS underlying_unwrap_address, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded + trace_succeeded FROM {{ ref('core__fact_traces') }} WHERE diff --git a/models/silver/defi/lending/init/silver__init_borrows.sql b/models/silver/defi/lending/init/silver__init_borrows.sql index 86c81c4..466b9e8 100644 --- a/models/silver/defi/lending/init/silver__init_borrows.sql +++ b/models/silver/defi/lending/init/silver__init_borrows.sql @@ -48,10 +48,7 @@ init_borrows AS ( contract_address AS token, 'INIT Capital' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -121,10 +118,7 @@ native_transfer AS ( to_address, value_precise_raw AS eth_value, 'WETH' AS eth_symbol, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, 18 AS eth_decimals, '0x4300000000000000000000000000000000000004' AS eth_address FROM diff --git a/models/silver/defi/lending/init/silver__init_deposits.sql b/models/silver/defi/lending/init/silver__init_deposits.sql index 1722679..1cef3b0 100644 --- a/models/silver/defi/lending/init/silver__init_deposits.sql +++ b/models/silver/defi/lending/init/silver__init_deposits.sql @@ -50,10 +50,7 @@ init_deposits AS ( -- receipt token 'INIT Capital' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -226,10 +223,7 @@ native_transfer AS ( to_address, value_precise_raw AS eth_value, 'WETH' AS eth_symbol, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, 18 AS eth_decimals, '0x4300000000000000000000000000000000000004' AS eth_address FROM diff --git a/models/silver/defi/lending/init/silver__init_liquidations.sql b/models/silver/defi/lending/init/silver__init_liquidations.sql index 02cec83..106051c 100644 --- a/models/silver/defi/lending/init/silver__init_liquidations.sql +++ b/models/silver/defi/lending/init/silver__init_liquidations.sql @@ -51,10 +51,7 @@ init_liquidations AS ( contract_address AS token, 'INIT Capital' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -132,10 +129,7 @@ position_owner AS ( utils.udf_hex_to_int( topics [2] :: STRING ) :: STRING AS posId, -- using string as it handles better than float - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/init/silver__init_repayments.sql b/models/silver/defi/lending/init/silver__init_repayments.sql index 6140cb3..007ca0b 100644 --- a/models/silver/defi/lending/init/silver__init_repayments.sql +++ b/models/silver/defi/lending/init/silver__init_repayments.sql @@ -51,10 +51,7 @@ init_repayments AS ( contract_address AS token, 'INIT Capital' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -84,10 +81,7 @@ native_transfer AS ( to_address AS wrapped_address, value_precise_raw AS eth_value, 'WETH' AS eth_symbol, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, 18 AS eth_decimals, '0x4300000000000000000000000000000000000004' AS eth_address FROM diff --git a/models/silver/defi/lending/init/silver__init_withdraws.sql b/models/silver/defi/lending/init/silver__init_withdraws.sql index 6120660..4be9346 100644 --- a/models/silver/defi/lending/init/silver__init_withdraws.sql +++ b/models/silver/defi/lending/init/silver__init_withdraws.sql @@ -49,10 +49,7 @@ init_redemption AS ( ) :: FLOAT AS redeemed_token_raw, 'INIT Capital' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -232,10 +229,7 @@ native_transfer AS ( from_address AS wrapped_address, to_address, value_precise_raw AS eth_value, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, 'WETH' AS eth_symbol, 18 AS eth_decimals, '0x4300000000000000000000000000000000000004' AS eth_address diff --git a/models/silver/defi/lending/juice/silver__juice_asset_details.sql b/models/silver/defi/lending/juice/silver__juice_asset_details.sql index 0cfafa1..c1408bf 100644 --- a/models/silver/defi/lending/juice/silver__juice_asset_details.sql +++ b/models/silver/defi/lending/juice/silver__juice_asset_details.sql @@ -78,10 +78,7 @@ tx_pull AS ( topics, DATA, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -134,10 +131,7 @@ trace_pull AS ( ) AS identifier, DATA, sub_traces, - CASE - WHEN trace_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS trace_succeeded, + trace_succeeded, error_reason, trace_index, fact_traces_id, @@ -253,10 +247,7 @@ logs_pull AS ( regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data, CONCAT('0x', SUBSTR(segmented_data [0], 25, 40)) AS contract_address, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -290,10 +281,7 @@ get_underlying AS ( topics, DATA, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/juice/silver__juice_borrows.sql b/models/silver/defi/lending/juice/silver__juice_borrows.sql index c7ba704..ec477d1 100644 --- a/models/silver/defi/lending/juice/silver__juice_borrows.sql +++ b/models/silver/defi/lending/juice/silver__juice_borrows.sql @@ -43,10 +43,7 @@ juice_borrows AS ( contract_address AS pool_address, 'Juice' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/juice/silver__juice_deposits.sql b/models/silver/defi/lending/juice/silver__juice_deposits.sql index 4184f4d..4b1d857 100644 --- a/models/silver/defi/lending/juice/silver__juice_deposits.sql +++ b/models/silver/defi/lending/juice/silver__juice_deposits.sql @@ -38,10 +38,7 @@ deposit_logs AS ( topics, DATA, event_removed, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/juice/silver__juice_liquidations.sql b/models/silver/defi/lending/juice/silver__juice_liquidations.sql index 7bf66cc..318e5cf 100644 --- a/models/silver/defi/lending/juice/silver__juice_liquidations.sql +++ b/models/silver/defi/lending/juice/silver__juice_liquidations.sql @@ -51,10 +51,7 @@ juice_liquidations AS ( ) :: INTEGER AS debtamountneeded_raw, 'Juice' AS platform, l.modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -87,10 +84,7 @@ token_transfer AS ( tx_hash, utils.udf_hex_to_int(DATA) AS seizeTokens_raw, event_index, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', @@ -130,10 +124,7 @@ debt_transfer AS ( debt_name, debt_address AS debt_token, debt_symbol AS debt_token_symbol, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/juice/silver__juice_repayments.sql b/models/silver/defi/lending/juice/silver__juice_repayments.sql index 997c66b..6a6fe92 100644 --- a/models/silver/defi/lending/juice/silver__juice_repayments.sql +++ b/models/silver/defi/lending/juice/silver__juice_repayments.sql @@ -43,10 +43,7 @@ juice_repayments AS ( ) :: INTEGER AS repayed_amount_raw, 'Juice' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/juice/silver__juice_withdraws.sql b/models/silver/defi/lending/juice/silver__juice_withdraws.sql index 4ed14ad..9c09b06 100644 --- a/models/silver/defi/lending/juice/silver__juice_withdraws.sql +++ b/models/silver/defi/lending/juice/silver__juice_withdraws.sql @@ -38,10 +38,7 @@ withdraw_logs AS ( DATA, topics, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_asset_details.sql b/models/silver/defi/lending/orbit/silver__orbit_asset_details.sql index a4053e9..2511521 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_asset_details.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_asset_details.sql @@ -14,10 +14,7 @@ WITH log_pull_1 AS ( block_timestamp, contract_address, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_borrows.sql b/models/silver/defi/lending/orbit/silver__orbit_borrows.sql index f0f853b..e5dd334 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_borrows.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_borrows.sql @@ -44,10 +44,7 @@ orbit_borrows AS ( contract_address AS token, 'Orbit' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_deposits.sql b/models/silver/defi/lending/orbit/silver__orbit_deposits.sql index 4f3c78e..87178ee 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_deposits.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_deposits.sql @@ -41,10 +41,7 @@ orbit_deposits AS ( CONCAT('0x', SUBSTR(segmented_data [0] :: STRING, 25, 40)) AS supplier, 'Orbit' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_liquidations.sql b/models/silver/defi/lending/orbit/silver__orbit_liquidations.sql index e53d709..e7c8a71 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_liquidations.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_liquidations.sql @@ -43,10 +43,7 @@ orbit_liquidations AS ( CONCAT('0x', SUBSTR(segmented_data [3] :: STRING, 25, 40)) AS tokenCollateral, 'Orbit' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_repayments.sql b/models/silver/defi/lending/orbit/silver__orbit_repayments.sql index 27d7bef..08ba20d 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_repayments.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_repayments.sql @@ -38,10 +38,7 @@ orbit_repayments AS ( ) :: INTEGER AS repayed_amount_raw, 'Orbit' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/silver/defi/lending/orbit/silver__orbit_withdraws.sql b/models/silver/defi/lending/orbit/silver__orbit_withdraws.sql index bb8e9a3..deff93f 100644 --- a/models/silver/defi/lending/orbit/silver__orbit_withdraws.sql +++ b/models/silver/defi/lending/orbit/silver__orbit_withdraws.sql @@ -41,10 +41,7 @@ orbit_redemptions AS ( CONCAT('0x', SUBSTR(segmented_data [0] :: STRING, 25, 40)) AS redeemer, 'Orbit' AS platform, modified_timestamp, - CASE - WHEN tx_status = 'SUCCESS' THEN TRUE - ELSE FALSE - END AS tx_succeeded, + tx_succeeded, CONCAT( tx_hash :: STRING, '-', diff --git a/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql b/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql index 2d5ad4f..0df4388 100644 --- a/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql +++ b/models/streamline/silver/decoder/realtime/streamline__decode_logs_realtime.sql @@ -50,7 +50,7 @@ candidate_logs AS ( INNER JOIN {{ ref('core__fact_event_logs') }} l USING (block_number) WHERE - l.tx_status = 'SUCCESS' + l.tx_succeeded AND l.inserted_timestamp :: DATE >= DATEADD('day', -5, SYSDATE()) ) SELECT