code: def test_streaming(deployment, query):
      outputs = []
  
      def callback(response):
          outputs.append(response[0].generated_text)
  
      deployment(query, streaming_fn=callback)
      assert outputs, "output is empty"
  
file_path: deepspeed-mii/tests/test_deployment.py
imports: import pytest
  import json
  import re
  import requests
  import subprocess
  import time
  import mii
label_desc: Use image node_id 2 for calling a global function with example usage: test_streaming(deployment, query) without return types