Scott Hood08/10/2022, 5:23 PM
to take a look at the failed pipelines last run? We had a question come up to where we want to do alert monitoring but in some cases we want to only alert if the prior run also failed and not just the individual run.
claire08/10/2022, 6:21 PM
@run_failure_sensor def check_multiple_runs_sensor(context: RunFailureSensorContext): latest_runs = context.instance.get_runs(RunsFilter(job_name="my_job"), limit=2) for run in latest_runs: if run.status == DagsterRunStatus.FAILURE: # your action here