fix(openai): Adds responses api streaming support

packages/opentelemetry-instrumentation-openai/opentelemetry/instrumentation/openai/utils.py

@@ -113,6 +113,36 @@ def wrapper(wrapped, instance, args, kwargs):
     return _with_chat_telemetry
 
 
+def _with_responses_telemetry_wrapper(func):
+    def _with_responses_telemetry(
+        tracer,
+        token_counter,
+        choice_counter,
+        duration_histogram,
+        exception_counter,
+        streaming_time_to_first_token,
+        streaming_time_to_generate,
+    ):
+        def wrapper(wrapped, instance, args, kwargs):
+            return func(
+                tracer,
+                token_counter,
+                choice_counter,
+                duration_histogram,
+                exception_counter,
+                streaming_time_to_first_token,
+                streaming_time_to_generate,
+                wrapped,
+                instance,
+                args,
+                kwargs,
+            )
+
+        return wrapper
+
+    return _with_responses_telemetry
+
+
 def _with_tracer_wrapper(func):
     def _with_tracer(tracer):
         def wrapper(wrapped, instance, args, kwargs):

packages/opentelemetry-instrumentation-openai/opentelemetry/instrumentation/openai/v1/__init__.py

@@ -302,12 +302,28 @@ def _instrument(self, **kwargs):
         self._try_wrap(
             "openai.resources.responses",
             "Responses.create",
-            responses_get_or_create_wrapper(tracer),
+            responses_get_or_create_wrapper(
+                tracer,
+                tokens_histogram,
+                chat_choice_counter,
+                duration_histogram,
+                chat_exception_counter,
+                streaming_time_to_first_token,
+                streaming_time_to_generate,
+            ),
         )
         self._try_wrap(
             "openai.resources.responses",
             "Responses.retrieve",
-            responses_get_or_create_wrapper(tracer),
+            responses_get_or_create_wrapper(
+                tracer,
+                tokens_histogram,
+                chat_choice_counter,
+                duration_histogram,
+                chat_exception_counter,
+                streaming_time_to_first_token,
+                streaming_time_to_generate,
+            ),
         )
         self._try_wrap(
             "openai.resources.responses",
@@ -317,12 +333,28 @@ def _instrument(self, **kwargs):
         self._try_wrap(
             "openai.resources.responses",
             "AsyncResponses.create",
-            async_responses_get_or_create_wrapper(tracer),
+            async_responses_get_or_create_wrapper(
+                tracer,
+                tokens_histogram,
+                chat_choice_counter,
+                duration_histogram,
+                chat_exception_counter,
+                streaming_time_to_first_token,
+                streaming_time_to_generate,
+            ),
         )
         self._try_wrap(
             "openai.resources.responses",
             "AsyncResponses.retrieve",
-            async_responses_get_or_create_wrapper(tracer),
+            async_responses_get_or_create_wrapper(
+                tracer,
+                tokens_histogram,
+                chat_choice_counter,
+                duration_histogram,
+                chat_exception_counter,
+                streaming_time_to_first_token,
+                streaming_time_to_generate,
+            ),
         )
         self._try_wrap(
             "openai.resources.responses",