def METHOD_NAME(unused_tcp_port):
    host = "localhost"
    url = f"ws://{host}:{unused_tcp_port}"
    reporter = Protobuf(experiment_url=url)
    job1 = Job({"name": "job1", "stdout": "stdout", "stderr": "stderr"}, 0)
    lines = []
    with _mock_ws_thread(host, unused_tcp_port, lines):
        reporter.report(
            Init(
                [job1],
                1,
                19,
                ens_id="ens_id",
                real_id=0,
                step_id=0,
                experiment_id="experiment_id",
            )
        )
        msg = Start(job1).with_error("massive_failure")
        reporter.report(msg)
        reporter.report(Finish())
    assert len(lines) == 2
    event = DispatcherMessage()
    event.ParseFromString(lines[1])
    # pylint: disable=no-member
    assert event.job.status == JOB_FAILURE
    assert event.job.error == "massive_failure"