Colin Mills
06/21/2023, 5:16 PMLatest materialization
via OpExecutionContext or other method?
We would like to implement branching logic depending on if this is the first time the asset/asset partition has ever been materializing versus a re-materialization or backfill.sandy
06/21/2023, 8:17 PMColin Mills
06/21/2023, 8:20 PM@asset
def asset_1(context):
instance = context.instance
materialization = instance.get_latest_materialization_event(AssetKey(["asset_1"])).asset_materialization