Chris Hansen
08/07/2022, 10:41 PMclaire
08/08/2022, 7:39 PM@op
def yields_partition_materializations():
partitions = [...] # filled partitions
for partition in partitions:
yield AssetMaterialization(asset_key="my_asset", partition=partition)
yield Output(5)
@job
def my_job():
yields_partition_materializations()
Chris Hansen
08/08/2022, 7:40 PMclaire
08/08/2022, 7:41 PM