code: def test_langfuse_logging_async():
      try:
          pre_langfuse_setup()
          litellm.set_verbose = True
          litellm.success_callback = ["langfuse"]
  
          async def _test_langfuse():
              response = await litellm.acompletion(
                  model="azure/chatgpt-v-2",
                  messages=[
                      {"role": "user", "content": "This is a test"}
                  ],
                  max_tokens=100,
                  temperature=0.7,
                  timeout=5,
                  user="test_user",
              )
              await asyncio.sleep(1)
              return response
  
          response = asyncio.run(_test_langfuse())
          print(f"response: {response}")
  
          # # check langfuse.log to see if there was a failed response
          search_logs("langfuse.log")
      except litellm.Timeout as e:
          pass
      except Exception as e:
          pytest.fail(f"An exception occurred - {e}")
  
file_path: litellm/litellm/tests/test_alangfuse.py
imports: import json
  import sys
  import os
  import io, asyncio
  import logging
  from litellm import completion
  import litellm
  import time
  import pytest
label_desc: Use image node_id 3 for calling a global function with example usage: test_langfuse_logging_async() and returns: response