async def METHOD_NAME(
    adaptive_batcher: AdaptiveBatcher,
    send_request: TestRequestSender,
    mocker,
):
    message = "This is an error"
    async def _async_exception():
        raise Exception(message)
    max_batch_size = adaptive_batcher._max_batch_size
    sent_requests = dict(
        await asyncio.gather(*[send_request() for _ in range(max_batch_size)])
    )
    adaptive_batcher._predict_fn = mocker.stub("_predict_fn")
    adaptive_batcher._predict_fn.return_value = _async_exception()
    await adaptive_batcher._batcher()
    for internal_id, _ in sent_requests.items():
        with pytest.raises(Exception) as err:
            await adaptive_batcher._async_responses[internal_id]
        assert str(err.value) == message