Eric Larson
06/01/2022, 2:32 PMowen
06/01/2022, 4:20 PM@asset
def my_querying_asset(context, some_upstream_asset):
last_materialization = context.instance.get_latest_materialization_events(asset_keys=[AssetKey("my_querying_asset")])
# ... do something
Eric Larson
06/01/2022, 4:58 PM@asset
def my_asset(upstream_asset, my_asset):