In previous versions of dagster I was using

asset_event.dagster_event.logging_tags['pipeline_tags']

to get tags of materialization run in asset_sensor, When updating to newest version there is no

pipeline_tags

key. I was using that to check if materialization was run by schedule/sensor or ad-hoc. Is there posiblity to check that in newest version? There is asset_event.tags but it not include required tags.

Hi jakub - I think this would work:

context.instance.get_run_by_id(asset_event.run_id).tags