https://dagster.io/ logo
#ask-community
Title
# ask-community
j

Jakub Zgrzebnicki

01/26/2023, 8:52 AM
Hi all, I'm using
asset_sensor
and I want to run only when materialization was caused by schedule. I did found
asset_event.dagster_event.logging_tags['pipeline_tags']
where I can see string in a form:
Copy code
{'.dagster/grpc_info': '{"host": "localhost", "socket": "/tmp/tmp0hhmzfvj"}', '.dagster/scheduled_execution_time': '2023-01-26T08:22:00+00:00', 'dagster/partition': '2023-01-19', 'dagster/partition_set': 'discount_report_daily_job_partition_set', 'dagster/run_key': '2023-01-19', 'dagster/schedule_name': 'discount_report_daily_job_schedule'}
Where I can check the name of the schedule that caused materialization. Is there a way to create a dict from it in an easy way from it? And is it correct way to check that materialization was caused by schedule?
4 Views