Credits Dagster OSS

credits.sql

with events as (select distinct

    DATE_FORMAT(timestamp, '%Y-%m')  as event_month,
    dagster_event_type,
    coalesce(run_id, '||', step_key) as step_id,
    count(1) as credits

from event_logs
where dagster_event_type = 'STEP_START'
or dagster_event_type = 'ASSET_MATERIALIZATION'
group by 1, 2, 3
)

select
    event_month,
    sum(credits) as sum_credits
from events
group by 1