diff --git a/models/silver/silver__all_unknown_balances.sql b/models/silver/silver__all_unknown_balances.sql index e3972fa..22f4867 100644 --- a/models/silver/silver__all_unknown_balances.sql +++ b/models/silver/silver__all_unknown_balances.sql @@ -1,5 +1,6 @@ {{ config( materialized = 'view', + post_hook = 'call silver.sp_bulk_get_balances()' ) }} WITH all_wallets AS ( @@ -48,9 +49,9 @@ unique_address_per_block_date AS ( LEFT OUTER JOIN max_block_id_per_date d ON d.block_timestamp_date = b.block_timestamp_date ), -all_lp_wallets as ( +all_lp_wallets AS ( SELECT - DISTINCT liquidity_provider_address as address + DISTINCT liquidity_provider_address AS address FROM {{ ref('silver__liquidity_provider_actions') }} WHERE @@ -67,12 +68,18 @@ possible_balances_needed AS ( * FROM unique_address_per_block_date - UNION - SELECT + UNION + SELECT max_block_id, address - FROM all_lp_wallets - CROSS JOIN (select distinct max_block_id from unique_address_per_block_date) + FROM + all_lp_wallets + CROSS JOIN ( + SELECT + DISTINCT max_block_id + FROM + unique_address_per_block_date + ) ) SELECT block_id,