How do I find all the asset materializations for a run?

[sryza]

I have a run ID. How do I get the asset materialization events from it?

[sryza]

You'll need a DagsterInstance object to access the Dagster database. You can get a DagsterInstance from any context variable, or via DagsterInstance.get.

Then, you can use get_records_for_run.

from typing import Sequence, cast
from dagster import AssetMaterialization, DagsterEventType, DagsterInstance


def get_assets_materializations_for_run(instance: DagsterInstance, run_id: str) -> Sequence[AssetMaterialization]:
    materialization_records = instance.get_records_for_run(
        run_id=run_id, of_type=DagsterEventType.ASSET_MATERIALIZATION
    ).records
    return [record.asset_materialization for record in materialization_records]