feat(solana): add executing_account_prefix predicates for instruction_calls partition pruning (#9674)

* feat(solana): add executing_account_prefix predicates for instruction_calls partition pruning

solana.instruction_calls is partitioned by (year, month, executing_account_prefix) where executing_account_prefix = substring(executing_account, 1, 2). With Base58, that's 12 * 58^2 = ~40k partitions/year.

Trino 479 cannot derive prefix predicates from full-address predicates (trinodb/trino#19455), so the partition column is not used unless we filter on it explicitly. Spellbook models all filter on the full executing_account, never on the prefix, so partition enumeration dominates planning time and pushes complex models over the 600s query.max-planning-time ceiling.

Adding 'AND executing_account_prefix = ''XX''' alongside the existing executing_account literal predicate gives Trino a constant partition predicate at plan time, cutting splits-generation by ~60%. Mirrors the account_activity fix in #9670.

Towards DWH-642

* feat(solana): extend executing_account_prefix predicate to amm staging macro and opensea

Adds the prefix predicate to:

- solana_amm_stg_raw_swaps macro -- one line that propagates to 14 DEX
  staging callers (alphaq, aquifer, aquifer_v2, bisonfi, byreal, goonfi,
  goonfi_v2, manifest, obric, scorch, solfi_v2, tessera, whalestreet,
  zerofi). The macro takes program_id as an argument so '{{ program_id[:2] }}'
  derives the prefix at compile time from each caller's literal.

- opensea_solana_token_trades (daily_spellbook) -- MemoSq4gqA... program
  with prefix 'Me'.

Same Jinja slice pattern as the per-model fixes in e2c5371 and the
account_activity fix in #9670. With the prior commit this covers all
literal-predicate readers of solana.instruction_calls in the spellbook
project.

Towards DWH-642

---------

Co-authored-by: jeff-dude <102681548+jeff-dude@users.noreply.github.com>

Author: a-monteiro

dbt_subprojects/daily_spellbook/models/_projects/opensea/solana/opensea_solana_token_trades.sql

@@ -14,6 +14,7 @@ WITH opensea_tx_ids AS (
     SELECT DISTINCT(tx_id) AS tx_id
     FROM {{ source('solana', 'instruction_calls') }}
     WHERE CONTAINS(log_messages, 'Program log: Memo (len 8): "865d8597"')
+        AND executing_account_prefix = 'Me'
         AND executing_account = 'MemoSq4gqABAXKb96qnH8TysNcWxMyWCqXgDLGmfcHr'
         AND block_time > TRY_CAST('2025-05-26 00:00' AS TIMESTAMP)
         {% if is_incremental() %}

dbt_subprojects/solana/macros/_sector/dex/solana_amm_stg_raw_swaps.sql

@@ -27,6 +27,7 @@ WITH swaps AS (
           ) }} AS surrogate_key
     FROM {{ source('solana', 'instruction_calls') }}
     WHERE 1=1
+        AND executing_account_prefix = '{{ program_id[:2] }}'
         AND executing_account = '{{ program_id }}'
         AND tx_success = true
         AND {{ discriminator_filter }}

dbt_subprojects/solana/models/_sector/dex/humidifi/humidifi_solana_stg_raw_swaps.sql

@@ -36,6 +36,7 @@ WITH swaps AS (
     FROM {{ source('solana', 'instruction_calls') }}
     WHERE 1=1
         AND executing_account = '9H6tua7jkLhdm3w8BvgpTn5LZNU7g4ZynDmCiNN3q6Rp'
+        AND executing_account_prefix = '9H'
         AND tx_success = true
         AND cardinality(account_arguments) > 8
         {% if is_incremental() -%}

dbt_subprojects/solana/models/_sector/dex/orca_whirlpool/orca_whirlpool_v2_stg_swaps.sql

@@ -273,6 +273,7 @@ FROM (
         AND ((sp.call_is_inner = false AND memo.inner_instruction_index = 1)
             OR (sp.call_is_inner = true AND memo.inner_instruction_index = sp.call_inner_instruction_index + 1))
         AND memo.executing_account = 'MemoSq4gqABAXKb96qnH8TysNcWxMyWCqXgDLGmfcHr'
+        AND memo.executing_account_prefix = 'Me'
         {% if is_incremental() -%}
         AND {{ incremental_predicate('memo.block_time') }}
         {% else -%}

dbt_subprojects/solana/models/_sector/dex/phantom_swapper/phantom_swapper_solana_fee_addresses.sql

@@ -27,6 +27,7 @@ FROM (
     , account_arguments[4] AS referraltokenaccount
     FROM {{ source('solana','instruction_calls') }}
     WHERE executing_account = 'REFER4ZgmyYx9c6He5XfaTMiGfdLwRnkV4RPp9t9iF3'
+    AND executing_account_prefix = 'RE'
     AND account_arguments[2] = '45ruCyfdRkWpRNGEqWzjCiXRHkZs8WXCLQ67Pnpye7Hp'
     AND TRY_CAST(data AS VARCHAR) like '%7d12465f%'
     AND block_time >= TIMESTAMP '2023-11-30' -- First date phantom ReferralTokenAccount created

dbt_subprojects/solana/models/_sector/dex/pumpdotfun/solana/pumpdotfun_solana_base_trades.sql

@@ -22,6 +22,7 @@ with
             , account_arguments[4] as bonding_curve_vault
         FROM {{ source('solana','instruction_calls') }}
         WHERE executing_account = '6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P'
+            AND executing_account_prefix = '6E'
             AND bytearray_substring(data,1,8) = 0x181ec828051c0777 --Create https://solscan.io/tx/2Vfq4gS9nq2jvpmZSxVXJ3uHGeheENXetwUus6KnhBzFu23Brqbt5EoNiTLds6jr72yZYGJ9YbMDG1BYKMRe3hSQ
             and tx_success = true
         {% if is_incremental() %}
@@ -52,6 +53,7 @@ with
             , outer_executing_account
         FROM {{ source('solana','instruction_calls') }}
         WHERE executing_account = '6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P'
+        AND executing_account_prefix = '6E'
         AND bytearray_substring(data,1,16) = 0xe445a52e51cb9a1dbddb7fd34ee661ee --SwapEvent
         and tx_success = true
         {% if is_incremental() %}

dbt_subprojects/solana/models/_sector/dex/pumpswap/pumpswap_solana_pools.sql

@@ -26,6 +26,7 @@ WITH pool_creation AS (
     FROM {{ source('solana','instruction_calls') }}
     WHERE varbinary_starts_with(data, 0xe445a52e51cb9a1db1310cd2a076a774)
         AND executing_account = 'pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA'
+        AND executing_account_prefix = 'pA'
         AND tx_success = true
     {% if is_incremental() %}
     AND {{incremental_predicate('block_time')}}

dbt_subprojects/solana/models/_sector/dex/sanctum_router/sanctum_router_base_trades.sql

@@ -163,6 +163,7 @@ token_amounts AS (
         AND ic.block_slot = b.block_slot
     WHERE 1=1
         AND ic.executing_account = 'TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA'
+        AND ic.executing_account_prefix = 'To'
         AND (
             (b.amount_type = 'mintTo' AND bytearray_substring(ic.data, 1, 1) = 0x07 AND ELEMENT_AT(ic.account_arguments, 1) = b.token_bought_mint_address)
             OR

dbt_subprojects/solana/models/_sector/gas/gas_solana_compute_limit.sql

@@ -24,6 +24,7 @@ SELECT
     ) as compute_limit
 FROM {{ source('solana', 'instruction_calls') }}
 WHERE executing_account = 'ComputeBudget111111111111111111111111111111'
+AND executing_account_prefix = 'Co'
 AND bytearray_substring(data,1,1) = 0x02
 AND inner_instruction_index is null
 {% if is_incremental() %}

dbt_subprojects/solana/models/_sector/gas/gas_solana_compute_unit_price.sql

@@ -24,6 +24,7 @@ SELECT
     ) AS compute_unit_price
 FROM {{ source('solana', 'instruction_calls') }}
 WHERE executing_account = 'ComputeBudget111111111111111111111111111111'
+AND executing_account_prefix = 'Co'
 AND bytearray_substring(data,1,1) = 0x03
 AND inner_instruction_index is null
 {% if is_incremental() %}