code: def test_completion_azure_stream_moderation_failure():
      try:
          customHandler = MyCustomHandler()
          litellm.callbacks = [customHandler]
          messages = [
              {
                  "role": "system",
                  "content": "You are a helpful assistant.",
              },
              {
                  "role": "user",
                  "content": "how do i kill someone",
              },
          ]
          try:
              response = completion(
                  model="azure/chatgpt-v-2",
                  messages=messages,
                  stream=True,
              )
              for chunk in response:
                  print(f"chunk: {chunk}")
                  continue
          except Exception as e:
              print(e)
          time.sleep(1)
          assert customHandler.failure == True
      except Exception as e:
          pytest.fail(f"Error occurred: {e}")
  
file_path: litellm/litellm/tests/test_custom_logger.py
imports: import sys, os, time, inspect, asyncio, traceback
  import pytest
  from litellm import completion, embedding
  import litellm
  from litellm.integrations.custom_logger import CustomLogger
label_desc: Use image node_id 2 for calling a global function with example usage: test_completion_azure_stream_moderation_failure() without return types