code: def __infer_stream(stub, model_name, model_input):
      with open(model_input, "rb") as f:
          data = f.read()
  
      input_data = {"data": data}
      responses = stub.StreamPredictions(
          inference_pb2.PredictionsRequest(
              model_name=model_name, input=input_data
          )
      )
  
      prediction = []
      for resp in responses:
          prediction.append(resp.prediction.decode("utf-8"))
  
      return " ".join(prediction)
  
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 6 for calling a global function with example usage: __infer_stream(stub, model_name, model_input) and returns: str