code: def start_stream(
      self, model_name: str, sequence_id: str, process_response
  ):
      if self._stream is not None:
          raise RuntimeError(
              "Cannot start InferStream2SimpleClient since "
              "InferStream2 was already started"
          )
  
      self._stream = InferStream2(
          model_name=model_name,
          sequence_id=sequence_id,
          process_response=process_response,
      )
      try:
          response_iterator = self._stub.StreamPredictions2(
              RequestIterator(self._stream)
          )
          self._stream.init_handler(response_iterator)
      except grpc.RpcError as e:
          print("start_stream received error:", e)
  
imports: import argparse
  import queue
  import threading
  from functools import partial
  import grpc
  import inference_pb2
  import inference_pb2_grpc
  import management_pb2
  import management_pb2_grpc
label_desc: Use image node_id 2 for calling the InferStream2SimpleClient obj's underlying member method code with example usage: obj.start_stream(model_name, sequence_id, process_response) without return types