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