def METHOD_NAME():
    events = defaultdict(list)
    @op
    def op_one():
        raise Exception("nope")
    def _event_callback(record):
        if record.is_dagster_event:
            events[record.dagster_event.event_type].append(record)
    single_op_job = JobDefinition(
        graph_def=GraphDefinition(
            name="single_op_job",
            node_defs=[op_one],
        ),
        logger_defs=get_loggers(_event_callback),
    )
    result = single_op_job.execute_in_process({"loggers": {"callback": {}}}, raise_on_error=False)
    assert not result.success
    start_event = single_dagster_event(events, DagsterEventType.STEP_START)
    assert start_event.job_name == "single_op_job"
    assert start_event.dagster_event.node_name == "op_one"
    assert start_event.level == logging.DEBUG
    failure_event = single_dagster_event(events, DagsterEventType.STEP_FAILURE)
    assert failure_event.job_name == "single_op_job"
    assert failure_event.dagster_event.node_name == "op_one"
    assert failure_event.level == logging.ERROR