code: def test_inference_stream2_apis():
      with open(
          os.path.join(
              os.path.dirname(__file__), inference_stream2_data_json
          ),
          "rb",
      ) as f:
          test_data = json.loads(f.read())
  
      for item in test_data:
          model_artifacts = test_utils.create_model_artifacts(
              item, force=True
          )
          managment_stub = test_gRPC_utils.get_management_stub()
          response = managment_stub.RegisterModel(
              management_pb2.RegisterModelRequest(
                  url=model_artifacts,
                  initial_workers=item["worker"],
                  synchronous=bool(item["synchronous"]),
                  model_name=item["model_name"],
              )
          )
  
          print(response.msg)
  
          t0 = threading.Thread(
              target=__infer_stream2,
              args=(
                  test_gRPC_utils.get_inference_stub(),
                  item["model_name"],
                  "seq_0",
                  str(item["expected"]),
              ),
          )
          t1 = threading.Thread(
              target=__infer_stream2,
              args=(
                  test_gRPC_utils.get_inference_stub(),
                  item["model_name"],
                  "seq_1",
                  str(item["expected"]),
              ),
          )
  
          t0.start()
          t1.start()
  
          t0.join()
          t1.join()
  
          response = managment_stub.UnregisterModel(
              management_pb2.UnregisterModelRequest(
                  model_name=item["model_name"],
              )
          )
  
          print(response.msg)
  
file_path: serve/test/pytest/test_gRPC_inference_api.py
imports: import json
  import os
  import threading
  from ast import literal_eval
  import inference_pb2
  import management_pb2
  import test_gRPC_utils
  import test_utils
label_desc: Use image node_id 9 for calling a global function with example usage: test_inference_stream2_apis() without return types