From 108ab61597d12c3608f54ceeadd23e98e1ae34c2 Mon Sep 17 00:00:00 2001 From: WHYTEWYLL Date: Thu, 14 Dec 2023 19:38:36 +0100 Subject: [PATCH] format --- .../gold/core/core__dim_contract_labels.sql | 2 +- models/gold/nft/nft__dim_moment_metadata.sql | 2 +- models/gold/price/price__fact_prices.sql | 50 ++++++++++--------- 3 files changed, 28 insertions(+), 26 deletions(-) diff --git a/models/gold/core/core__dim_contract_labels.sql b/models/gold/core/core__dim_contract_labels.sql index 64cd191..6fe0c36 100644 --- a/models/gold/core/core__dim_contract_labels.sql +++ b/models/gold/core/core__dim_contract_labels.sql @@ -60,4 +60,4 @@ FROM PARTITION BY event_contract ORDER BY _inserted_timestamp DESC - ) = 1 \ No newline at end of file + ) = 1 diff --git a/models/gold/nft/nft__dim_moment_metadata.sql b/models/gold/nft/nft__dim_moment_metadata.sql index 8c13f23..47571e8 100644 --- a/models/gold/nft/nft__dim_moment_metadata.sql +++ b/models/gold/nft/nft__dim_moment_metadata.sql @@ -108,4 +108,4 @@ FROM PARTITION BY dim_moment_metadata_id ORDER BY _inserted_timestamp DESC - ) = 1 \ No newline at end of file + ) = 1 diff --git a/models/gold/price/price__fact_prices.sql b/models/gold/price/price__fact_prices.sql index c25f4d9..1a8ad73 100644 --- a/models/gold/price/price__fact_prices.sql +++ b/models/gold/price/price__fact_prices.sql @@ -33,7 +33,7 @@ prices_swaps_cw AS ( NULL AS prices_swaps_id, NULL AS inserted_timestamp, NULL AS modified_timestamp - FROM + FROM {{ ref('silver__prices_swaps') }} ), prices_swaps_s AS ( @@ -100,31 +100,33 @@ viewnion AS ( LEFT JOIN token_labels l USING (token_contract) ) SELECT - TIMESTAMP, - token, - symbol, - token_contract, - price_usd, - source, - tx_id, - COALESCE ( - prices_swaps_id, - {{ dbt_utils.generate_surrogate_key(['TIMESTAMP','TOKEN', 'TOKEN_CONTRACT', 'SOURCE']) }} - ) AS price_act_prices, - COALESCE ( - inserted_timestamp, - TIMESTAMP - ) AS inserted_timestamp, - COALESCE ( - modified_timestamp, - TIMESTAMP - ) AS modified_timestamp + TIMESTAMP, + token, + symbol, + token_contract, + price_usd, + source, + tx_id, + COALESCE ( + prices_swaps_id, + {{ dbt_utils.generate_surrogate_key(['TIMESTAMP','TOKEN', 'TOKEN_CONTRACT', 'SOURCE']) }} + ) AS price_act_prices, + COALESCE ( + inserted_timestamp, + TIMESTAMP + ) AS inserted_timestamp, + COALESCE ( + modified_timestamp, + TIMESTAMP + ) AS modified_timestamp FROM viewnion WHERE - TIMESTAMP IS NOT NULL -qualify ROW_NUMBER() over ( - PARTITION BY TIMESTAMP, TOKEN, TOKEN_CONTRACT, SOURCE + TIMESTAMP IS NOT NULL qualify ROW_NUMBER() over ( + PARTITION BY TIMESTAMP, + token, + token_contract, + source ORDER BY _inserted_timestamp DESC - ) = 1 \ No newline at end of file + ) = 1