code: def test_redis_cache_completion_stream():
      try:
          litellm.success_callback = []
          litellm._async_success_callback = []
          litellm.callbacks = []
          litellm.set_verbose = True
          random_number = random.randint(
              1, 100000
          )  # add a random number to ensure it's always adding / reading from cache
          messages = [
              {
                  "role": "user",
                  "content": f"write a one sentence poem about: {random_number}",
              }
          ]
          litellm.cache = Cache(
              type="redis",
              host=os.environ["REDIS_HOST"],
              port=os.environ["REDIS_PORT"],
              password=os.environ["REDIS_PASSWORD"],
          )
          print("test for caching, streaming + completion")
          response1 = completion(
              model="gpt-3.5-turbo",
              messages=messages,
              max_tokens=40,
              temperature=0.2,
              stream=True,
          )
          response_1_content = ""
          for chunk in response1:
              print(chunk)
              response_1_content += chunk.choices[0].delta.content or ""
          print(response_1_content)
          time.sleep(0.5)
          response2 = completion(
              model="gpt-3.5-turbo",
              messages=messages,
              max_tokens=40,
              temperature=0.2,
              stream=True,
          )
          response_2_content = ""
          for chunk in response2:
              print(chunk)
              response_2_content += chunk.choices[0].delta.content or ""
          print("\nresponse 1", response_1_content)
          print("\nresponse 2", response_2_content)
          assert (
              response_1_content == response_2_content
          ), f"Response 1 != Response 2. Same params, Response 1{response_1_content} != Response 2{response_2_content}"
          litellm.success_callback = []
          litellm.cache = None
          litellm.success_callback = []
          litellm._async_success_callback = []
      except Exception as e:
          print(e)
          litellm.success_callback = []
          raise e
      """
  
      1 & 2 should be exactly the same 
      """
  
imports: import sys, os, uuid
  import time
  import traceback
  from dotenv import load_dotenv
  import os
  import pytest
  import litellm
  from litellm import embedding, completion
  from litellm.caching import Cache
  import random
  import hashlib
  import random
  import string
label_desc: Use image node_id 9 for calling a global function with example usage: test_redis_cache_completion_stream() without return types