Fixed tests

Author: antonpirker

sentry_sdk/integrations/openai.py

@@ -577,12 +577,12 @@ async def _execute_async(f, *args, **kwargs):
             return e.value
 
     @wraps(f)
-    async def _sentry_patched_create_async(*args, **kwargs):
+    async def _sentry_patched_responses_async(*args, **kwargs):
         # type: (Any, Any) -> Any
         integration = sentry_sdk.get_client().get_integration(OpenAIIntegration)
         if integration is None:
             return await f(*args, **kwargs)
 
         return await _execute_async(f, *args, **kwargs)
 
-    return _sentry_patched_create_async
+    return _sentry_patched_responses_async

tests/integrations/openai/test_openai.py

@@ -1076,6 +1076,7 @@ def test_error_in_responses_api(sentry_init, capture_events):
     )
 
 
+@pytest.mark.asyncio
 @pytest.mark.skipif(SKIP_RESPONSES_TESTS, reason="Responses API not available")
 async def test_ai_client_span_responses_async_api(sentry_init, capture_events):
     sentry_init(
@@ -1086,7 +1087,7 @@ async def test_ai_client_span_responses_async_api(sentry_init, capture_events):
     events = capture_events()
 
     client = AsyncOpenAI(api_key="z")
-    client.responses._post = mock.Mock(return_value=EXAMPLE_RESPONSE)
+    client.responses._post = AsyncMock(return_value=EXAMPLE_RESPONSE)
 
     with start_transaction(name="openai tx"):
         await client.responses.create(
@@ -1115,6 +1116,7 @@ async def test_ai_client_span_responses_async_api(sentry_init, capture_events):
     }
 
 
+@pytest.mark.asyncio
 @pytest.mark.skipif(SKIP_RESPONSES_TESTS, reason="Responses API not available")
 async def test_error_in_responses_async_api(sentry_init, capture_events):
     sentry_init(
@@ -1125,7 +1127,7 @@ async def test_error_in_responses_async_api(sentry_init, capture_events):
     events = capture_events()
 
     client = AsyncOpenAI(api_key="z")
-    client.responses._post = mock.Mock(
+    client.responses._post = AsyncMock(
         side_effect=OpenAIError("API rate limit reached")
     )