graph TD
    subgraph <UUID>[eng1]
        events["events<br/>type: source<br/>catalog: lake"]
    end
    subgraph <UUID>[eng2]
        agg_events["agg_events<br/>type: sql"]
    end
    subgraph <UUID>[eng1]
        write_agg["write_agg<br/>type: sink<br/>catalog: warehouse"]
    end
    events --> agg_events
    agg_events --> write_agg
    events -->|⚡ materialize| agg_events
    agg_events -->|⚡ materialize| write_agg
