Alex Service
02/25/2022, 4:19 PMmetadata_entries
to a more convenient format; it takes advantage of dagster’s design decision to subclass NamedTuple and include the data as the first value
def get_asset_metadata(ass: AssetMaterialization, metadata_label=None):
metadata_filter = lambda entry: (metadata_label is None) or (entry.label == metadata_label)
return {entry.label: entry.entry_data[0]
for entry in
filter(metadata_filter,
ass.event_log_entry.dagster_event.event_specific_data.materialization.metadata_entries)}