def get_assets_for_run_id(graphene_info, run_id):
    from ..schema.pipelines.pipeline import GrapheneAsset
    check.str_param(run_id, 'run_id')
    records = graphene_info.context.instance.all_logs(run_id)
    asset_keys = [record.dagster_event.asset_key for record in records if (record.is_dagster_event and record.dagster_event.asset_key)]
    return [GrapheneAsset(key=asset_key) for asset_key in asset_keys]
def get_assets_for_run_id(graphene_info, run_id):
    from ..schema.pipelines.pipeline import GrapheneAsset
    check.str_param(run_id, 'run_id')
    records = graphene_info.context.instance.all_logs(run_id)
    asset_keys = [record.dagster_event.asset_key for record in records if (record.is_dagster_event and record.dagster_event.asset_key)]
    return [GrapheneAsset(key=asset_key) for asset_key in asset_keys]