async def METHOD_NAME(self, req: InferenceRequest) -> InferenceResponse:
    internal_id, _ = await self._queue_request(req)
    self._start_batcher_if_needed()
    return await self._wait_response(internal_id)