Grigoriy Sterin
05/24/2022, 4:38 PMasset_sensor
? I tried doing this, but it didn't work (dagster_event doesn't have metadata
field):
@asset_sensor(asset_key=AssetKey("my-asset-key"), job=my_job)
def my_asset_sensor(context, asset_event):
yield RunRequest(
run_key=context.cursor,
run_config={
"ops": {
"my_op": {
"config": {
"txt_metadata_from_asset": asset_event.dagster_event.metadata["txt_field"]
}
}
}
}
)
Grigoriy Sterin
05/25/2022, 3:02 PMsean
05/25/2022, 3:21 PM