def METHOD_NAME(
    mock_scribereader,
    scribereader_output,
    mock_scribe_env_to_locations,
):
    mock_scribereader.get_tail_host_and_port.return_value = "localhost", 12345
    mock_scribereader.get_stream_tailer.return_value = scribereader_output
    assert (
        len(
            [x for x in read_oom_events_from_scribe("fake_cluster", "fake_superregion")]
        )
        == 4
    )
    assert mock_scribe_env_to_locations.call_args_list == [
        mock.call("fake_scribe_env"),
    ]