The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

Hey Y'all I'm wondering if there is a way to point a `ScheduleDefinition` 's `should_execute` filter to another pipeline having completed. I'm wondering if there is a way to set dependencies like Pipeline B executes at scheduled time if and only if the last run of Pipeline A successfully ran.

Hey <@U0109V2T2S2>, this is definitely possible. The `should_execute` function is passed a `context` which an instance of `ScheduleExecutionContext`. On this we can access `context.instance` which lets us query the run storage using the `get_runs` method

To do what you’re describing:

```def should_execute(context):
    run_filter = PipelineRunsFilter(pipeline_name="Pipeline A")
    runs = context.instance.get_runs(run_filter, limit=1)
    if not len(runs):
        return False

    latest_run = runs[0]
    if latest_run.status == PipelineRunStatus.SUCCESS:
        return True

    return False```

Oh this is amazing! Thank you <@UL7C8DRKN> :smile: