Elizabeth
02/03/2022, 7:29 PMget_runs
based on run_key
in a sensor? It doesn’t appear to be an option for PipelineRunsFilter
.owen
02/03/2022, 7:37 PMrun_key
gets added to a tag on the job run (specifically, {"dagster/run_key": <your_run_key>}
), so you can query for it through the tags argument on PipelineRunsFilterElizabeth
02/03/2022, 7:44 PMruns = context.instance.get_runs(
filters=PipelineRunsFilter(
tags={"dagster/run_key": 'foo'}
)
)
yuhan
06/16/2022, 12:27 AMDagster Bot
06/16/2022, 12:27 AM