maybeyonassushi_monthly_sushi_rewards
    with
    pools as (
    select distinct
    pool_name,
    pool_address
    from ethereum.dex_swaps
    where platform = 'sushiswap'
    and direction = 'IN'
    ),
    pool_names as (
    select distinct
    address_name,
    user_address
    from ethereum.erc20_balances
    where user_address in (select pool_address from pools)
    and amount_usd is not null
    and address_name is not null
    ),
    pool_init as (
    select
    block_timestamp,
    tx_id,
    event_inputs:pid as pid,
    event_inputs:lpToken as lpToken,
    event_inputs:rewarder::string as rewardContract,
    event_inputs:allocPoint as allocPoint
    from ethereum.events_emitted
    where event_name = 'LogPoolAddition'
    and event_removed = 'FALSE'
    and tx_to_address='0x19b3eb3af5d93b77a5619b047de0eed7115a19e7'
    ),
    pool_rewards_update as (
    select
    e.block_timestamp,
    e.tx_id,
    event_inputs:pid as pid,
    Run a query to Download Data