def METHOD_NAME(self):
    """ModelRuntimeServicer.loadModel will abort a long-running load"""
    model = "test-any-model-id"
    request = model_runtime_pb2.LoadModelRequest(modelId=model)
    context = Fixtures.build_context(model)
    mock_manager = MagicMock()
    started = Event()
    def never_return(*args, **kwargs):
        started.set()
        while True:
            time.sleep(0.01)
    mock_manager.load_model.side_effect = never_return
    load_thread = Thread(target=self.servicer.loadModel, args=(request, context))
    with catch_threading_exception() as cm:
        with patch.object(self.servicer, "model_manager", mock_manager):
            load_thread.start()
            started.wait()
            context.cancel()
            load_thread.join(10)
        self.assertFalse(load_thread.is_alive())
        # Make sure the correct exception was raised
        assert cm.exc_type == AbortedException