def METHOD_NAME(capsys):
    r"""B =========== C
    //             \\
    A                F (skipped)
    \\             //
    D (fails) == E (skipped).
    """
    op_a = create_root_success_op("op_a")
    @op
    def op_b(_, in_):
        return in_
    @op
    def op_c(_, in_):
        return in_
    @op
    def op_d(_, _in):
        check.failed("user error")
    @op
    def op_e(_, in_):
        return in_
    @op
    def op_f(_, in_, _in2):
        return in_
    @job
    def job_def():
        a_result = op_a()
        op_f(op_c(op_b(a_result)), op_e(op_d(a_result)))
    result = job_def.execute_in_process(raise_on_error=False)
    assert did_op_succeed("op_a", result)
    assert did_op_succeed("op_b", result)
    assert did_op_succeed("op_c", result)
    assert did_op_fail("op_d", result)
    failure_events = result.filter_events(
        lambda evt: evt.step_key == "op_d" and evt.is_step_failure
    )
    assert len(failure_events) == 1
    failure_event = failure_events.pop()
    assert failure_event.step_failure_data.error.cause.cls_name == "CheckError"
    err_logs = capsys.readouterr().err
    assert did_op_skip("op_e", err_logs)
    assert did_op_skip("op_f", err_logs)
    # Demonstrate that no step-skip event is launched off for op e
    assert (
        len(result.filter_events(lambda evt: evt.step_key == "op_e" and evt.is_step_skipped)) == 0
    )
    # Demonstrate that no step-skip event is launched off for op f
    assert (
        len(result.filter_events(lambda evt: evt.step_key == "op_f" and evt.is_step_skipped)) == 0
    )