code: def test_completion_deep_infra_stream():
      # deep infra currently includes role in the 2nd chunk
      # waiting for them to make a fix on this
      try:
          messages = [
              {
                  "role": "system",
                  "content": "You are a helpful assistant.",
              },
              {
                  "role": "user",
                  "content": "how does a court case get to the Supreme Court?",
              },
          ]
          print("testing deep infra streaming")
          response = completion(
              model="deepinfra/meta-llama/Llama-2-70b-chat-hf",
              messages=messages,
              stream=True,
              max_tokens=80,
          )
  
          complete_response = ""
          # Add any assertions here to check the response
          for idx, chunk in enumerate(response):
              chunk, finished = streaming_format_tests(idx, chunk)
              if finished:
                  break
              complete_response += chunk
          if complete_response.strip() == "":
              raise Exception("Empty response received")
          print(f"completion_response: {complete_response}")
      except Exception as e:
          pytest.fail(f"Error occurred: {e}")
  
imports: import sys, os, asyncio
  import traceback
  import time, pytest
  from dotenv import load_dotenv
  import litellm
  from litellm import completion, acompletion, AuthenticationError, BadRequestError, RateLimitError, ModelResponse
label_desc: Use image node_id 13 for calling a global function with example usage: test_completion_deep_infra_stream() without return types