Roman Maliushkin
12/29/2022, 2:03 PMAssetMaterialization
event?
For instance, I have `AssetMaterialization`:
AssetMaterialization(
asset_key=AssetKey("my_key"),
description="Update asset",
metadata={
"date": "2022-12-01"
},
)
Then I would like to get these value in asset_sensor
method:
@asset_sensor(asset_key=AssetKey("my_key"), job=dbx_to_druid_general_job)
def internal_bi_bid_funnel_etl_job_sensor(context: SensorEvaluationContext, asset_event: EventLogEntry):
...
Daniel Mosesson
12/29/2022, 2:06 PMDaniel Mosesson
12/29/2022, 2:09 PMpipelineRunsOrError(filter: $runsFilter, limit: $limit) {
... on PipelineRuns {
results {
assertMaterializations {
<get data here>
}
}
}
}
Should be pretty closeDaniel Mosesson
12/29/2022, 2:10 PMasset_sensor
Bartek Marczak
12/29/2022, 2:24 PMAssetMaterialization
including the metadata through the asset_event
parameter. Specifically: asset_event.dagster_event.event_specific_data.materialization