code: def test_completion_ollama_hosted_stream():
      try:
          litellm.set_verbose = True
          response = completion(
              model="ollama/phi",
              messages=messages,
              max_tokens=10,
              num_retries=3,
              timeout=20,
              api_base="https://test-ollama-endpoint.onrender.com",
              stream=True,
          )
          # Add any assertions here to check the response
          complete_response = ""
          # Add any assertions here to check the response
          for idx, init_chunk in enumerate(response):
              chunk, finished = streaming_format_tests(idx, init_chunk)
              complete_response += chunk
              if finished:
                  assert isinstance(
                      init_chunk.choices[0],
                      litellm.utils.StreamingChoices,
                  )
                  break
          if complete_response.strip() == "":
              raise Exception("Empty response received")
          print(f"complete_response: {complete_response}")
      except Exception as e:
          if "try pulling it first" in str(e):
              return
          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 9 for calling a global function with example usage: test_completion_ollama_hosted_stream() without return types