code: def infer_stream2(model_name, sequence_id, input_files):
      response_queue = queue.Queue()
      process_response_func = partial(
          InferStream2.default_process_response, response_queue
      )
  
      client = InferStream2SimpleClient()
      try:
          client.start_stream(
              model_name=model_name,
              sequence_id=sequence_id,
              process_response=process_response_func,
          )
          sequence = input_files.split(",")
  
          for input_file in sequence:
              client.async_send_infer(input_file.strip())
  
          for i in range(0, len(sequence)):
              response = response_queue.get()
              print(str(response))
  
          print("Sequence completed!")
  
      except grpc.RpcError as e:
          print("infer_stream2 received error", e)
          exit(1)
      finally:
          client.stop_stream()
          client.stop()
  
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 5 for calling a global function with example usage: infer_stream2(model_name, sequence_id, input_files) without return types