add overwrite mechanism for stream_options

Author: Ddper

src/agents/model_settings.py

@@ -54,6 +54,10 @@ class ModelSettings:
     """Whether to store the generated model response for later retrieval.
     Defaults to True if not provided."""
 
+    include_usage: bool | None = None
+    """Whether to include usage chunk.
+    Defaults to True if not provided."""
+
     def resolve(self, override: ModelSettings | None) -> ModelSettings:
         """Produce a new ModelSettings by overlaying any non-None values from the
         override on top of this instance."""

src/agents/models/openai_chatcompletions.py

@@ -521,6 +521,8 @@ async def _fetch_response(
         reasoning_effort = model_settings.reasoning.effort if model_settings.reasoning else None
         store = _Converter.get_store_param(self._get_client(), model_settings)
 
+        stream_options = _Converter.get_stream_options_param(self._get_client(), model_settings)
+
         ret = await self._get_client().chat.completions.create(
             model=self.model,
             messages=converted_messages,
@@ -534,7 +536,7 @@ async def _fetch_response(
             response_format=response_format,
             parallel_tool_calls=parallel_tool_calls,
             stream=stream,
-            stream_options={"include_usage": True} if stream else NOT_GIVEN,
+            stream_options=self._non_null_or_not_given(stream_options),
             store=self._non_null_or_not_given(store),
             reasoning_effort=self._non_null_or_not_given(reasoning_effort),
             extra_headers=_HEADERS,
@@ -574,6 +576,14 @@ def get_store_param(cls, client: AsyncOpenAI, model_settings: ModelSettings) ->
         default_store = True if str(client.base_url).startswith("https://api.openai.com") else None
         return model_settings.store if model_settings.store is not None else default_store
 
+    @classmethod
+    def get_stream_options_param(cls, client: AsyncOpenAI, model_settings: ModelSettings) -> dict | None:
+        default_include_usage = True if str(client.base_url).startswith("https://api.openai.com") else None
+        include_usage = model_settings.include_usage if model_settings.include_usage is not None \
+            else default_include_usage
+        stream_options = {"include_usage": include_usage} if include_usage is not None else NOT_GIVEN
+        return stream_options
+
     @classmethod
     def convert_tool_choice(
         cls, tool_choice: Literal["auto", "required", "none"] | str | None