code: def __init__(
      self,
      downstream: RayServeHandle,
      *,
      batch_size: int,
      num_trials: int,
      trial_runtime: float,
  ):
      logging.getLogger("ray.serve").setLevel(logging.WARNING)
  
      self._h: DeploymentHandle = downstream.options(
          use_new_handle_api=True
      )
      self._batch_size = batch_size
      self._num_trials = num_trials
      self._trial_runtime = trial_runtime
  
file_path: ray/python/ray/serve/_private/benchmarks/handle_throughput.py
imports: import asyncio
  import logging
  from typing import Tuple
  import click
  from ray import serve
  from ray.serve._private.benchmarks.common import run_throughput_benchmark
  from ray.serve.handle import DeploymentHandle, RayServeHandle
label_desc: Use image node_id 1 to create a new Caller object  with example: obj = Caller(downstream)