Merge branch 'feat/gen_from_reasoning' into 'integration_2025-10-30_1074886721538'

feat: [development task] ark runtime (1783638)

See merge request iaasng/volcengine-python-sdk!892

Author: BitsAdmin

volcenginesdkarkruntime/resources/encryption.py

@@ -10,6 +10,7 @@
 import json
 import warnings
 from copy import deepcopy
+from urllib.parse import urlparse
 from typing import (
     Union,
     Iterable,
@@ -187,14 +188,21 @@ def _process_messages(
                     if part.get("type", None) == "text":
                         part["text"] = f(part["text"])
                     elif part.get("type", None) == "image_url":
-                        if part["image_url"]["url"].startswith("data:"):
+                        parse_result = urlparse(part["image_url"]["url"])
+                        if parse_result.scheme == 'data':
                             part["image_url"]["url"] = f(
                                 part["image_url"]["url"])
-                        else:
+                        elif parse_result.scheme == 'http' or parse_result.scheme == 'https':
                             warnings.warn(
                                 "encryption is not supported for image url, "
                                 "please use base64 image if you want encryption"
                             )
+                        else:
+                            raise TypeError(
+                                "encryption is not supported for image url scheme {}".format(
+                                    parse_result
+                                )
+                            )
                     else:
                         raise TypeError(
                             "encryption is not supported for content type {}".format(

volcenginesdkarkruntime/resources/responses/responses.py

@@ -1,4 +1,3 @@
-
 # Copyright (c) [2025] [OpenAI]
 # Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
 # SPDX-License-Identifier: Apache-2.0
@@ -41,12 +40,15 @@
 from ...types.responses.response_stream_event import ResponseStreamEvent
 from ...types.responses.response_text_config_param import ResponseTextConfigParam
 from ...types.responses.response_caching_param import ResponseCaching
+from ...types.shared_params import Reasoning
 from volcenginesdkarkruntime.types.shared_params.thinking import Thinking
 
 __all__ = ["Responses", "AsyncResponses"]
 
 
-def _add_beta_headers(extra_headers: Headers | None = None, tools: Iterable[ToolParam] | None = ()) -> Headers:
+def _add_beta_headers(
+    extra_headers: Headers | None = None, tools: Iterable[ToolParam] | None = ()
+) -> Headers:
     if tools is None:
         return extra_headers
     for tool_param in tools:
@@ -95,6 +97,7 @@ def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | None = None,
+        reasoning: Optional[Reasoning] | None = None,
     ) -> Response | Stream[ResponseStreamEvent]:
         extra_headers = _add_beta_headers(extra_headers, tools)
         resp = self._post(
@@ -117,6 +120,7 @@ def create(
                 "top_p": top_p,
                 "max_tool_calls": max_tool_calls,
                 "expire_at": expire_at,
+                "reasoning": reasoning,
             },
             options=make_request_options(
                 extra_headers=extra_headers,
@@ -134,14 +138,15 @@ def retrieve(
         self,
         response_id: str,
         *,
-
         extra_headers: Headers | None = None,
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None = None,
     ) -> Response:
         if not response_id:
-            raise ValueError(f"Expected a non-empty value for `response_id` but received {response_id!r}")
+            raise ValueError(
+                f"Expected a non-empty value for `response_id` but received {response_id!r}"
+            )
         return self._get(
             f"/responses/{response_id}",
             options=make_request_options(
@@ -165,12 +170,17 @@ def delete(
         timeout: float | httpx.Timeout | None = None,
     ) -> None:
         if not response_id:
-            raise ValueError(f"Expected a non-empty value for `response_id` but received {response_id!r}")
+            raise ValueError(
+                f"Expected a non-empty value for `response_id` but received {response_id!r}"
+            )
         extra_headers = {"Accept": "*/*", **(extra_headers or {})}
         return self._delete(
             f"/responses/{response_id}",
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
             ),
             cast_to=type(None),
         )
@@ -210,6 +220,7 @@ async def create(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | None = None,
+        reasoning: Optional[Reasoning] | None = None,
     ) -> Response | AsyncStream[ResponseStreamEvent]:
         extra_headers = _add_beta_headers(extra_headers, tools)
         resp = await self._post(
@@ -232,6 +243,7 @@ async def create(
                 "top_p": top_p,
                 "max_tool_calls": max_tool_calls,
                 "expire_at": expire_at,
+                "reasoning": reasoning,
             },
             options=make_request_options(
                 extra_headers=extra_headers,
@@ -247,17 +259,18 @@ async def create(
         return resp
 
     async def retrieve(
-            self,
-            response_id: str,
-            *,
-
-            extra_headers: Headers | None = None,
-            extra_query: Query | None = None,
-            extra_body: Body | None = None,
-            timeout: float | httpx.Timeout | None = None,
+        self,
+        response_id: str,
+        *,
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None = None,
     ) -> Response:
         if not response_id:
-            raise ValueError(f"Expected a non-empty value for `response_id` but received {response_id!r}")
+            raise ValueError(
+                f"Expected a non-empty value for `response_id` but received {response_id!r}"
+            )
         return await self._get(
             f"/responses/{response_id}",
             options=make_request_options(
@@ -272,21 +285,26 @@ async def retrieve(
         )
 
     async def delete(
-            self,
-            response_id: str,
-            *,
-            extra_headers: Headers | None = None,
-            extra_query: Query | None = None,
-            extra_body: Body | None = None,
-            timeout: float | httpx.Timeout | None = None,
+        self,
+        response_id: str,
+        *,
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None = None,
     ) -> None:
         if not response_id:
-            raise ValueError(f"Expected a non-empty value for `response_id` but received {response_id!r}")
+            raise ValueError(
+                f"Expected a non-empty value for `response_id` but received {response_id!r}"
+            )
         extra_headers = {"Accept": "*/*", **(extra_headers or {})}
         return await self._delete(
             f"/responses/{response_id}",
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
             ),
             cast_to=type(None),
         )

volcenginesdkarkruntime/types/__init__.py

@@ -16,6 +16,8 @@
     ResponseFormatText as ResponseFormatText,
     ResponseFormatJSONObject as ResponseFormatJSONObject,
     ResponseFormatJSONSchema as ResponseFormatJSONSchema,
+    Reasoning as Reasoning,
+    ReasoningEffort as ReasoningEffort,
 )
 from .embedding import Embedding as Embedding
 from .completion_usage import CompletionUsage as CompletionUsage

volcenginesdkarkruntime/types/responses/audio_chunking_strategy.py

@@ -0,0 +1,30 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from typing_extensions import Literal
+
+from ..._models import BaseModel
+
+__all__ = ["AudioChunkingStrategy"]
+
+
+class AudioChunkingStrategy(BaseModel):
+    type: Literal["server_vad"]
+
+    prefix_padding_ms: Optional[int] = None
+
+    silence_duration_ms: Optional[int] = None
+
+    threshold: Optional[float] = None

volcenginesdkarkruntime/types/responses/audio_chunking_strategy_param.py

@@ -0,0 +1,28 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from typing_extensions import Literal, Required, TypedDict
+
+__all__ = ["AudioChunkingStrategyParam"]
+
+
+class AudioChunkingStrategyParam(TypedDict, total=False):
+    type: Required[Literal["server_vad"]]
+
+    prefix_padding_ms: Optional[int]
+
+    silence_duration_ms: Optional[int]
+
+    threshold: Optional[float]

volcenginesdkarkruntime/types/responses/image_process_grounding_options.py

@@ -0,0 +1,23 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from ..._models import BaseModel
+
+__all__ = ["ImageProcessGroundingOptions"]
+
+
+class ImageProcessGroundingOptions(BaseModel):
+    type: Optional[str] = None
+    """`disabled` or `enabled`."""

volcenginesdkarkruntime/types/responses/image_process_grounding_options_param.py

@@ -0,0 +1,23 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from typing_extensions import TypedDict
+
+__all__ = ["ImageProcessGroundingOptionsParam"]
+
+
+class ImageProcessGroundingOptionsParam(TypedDict, total=False):
+    type: Optional[str]
+    """`disabled` or `enabled`."""

volcenginesdkarkruntime/types/responses/image_process_point_options.py

@@ -0,0 +1,23 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from ..._models import BaseModel
+
+__all__ = ["ImageProcessPointOptions"]
+
+
+class ImageProcessPointOptions(BaseModel):
+    type: Optional[str] = None
+    """`disabled` or `enabled`."""

volcenginesdkarkruntime/types/responses/image_process_point_options_param.py

@@ -0,0 +1,23 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from typing_extensions import TypedDict
+
+__all__ = ["ImageProcessPointOptionsParam"]
+
+
+class ImageProcessPointOptionsParam(TypedDict, total=False):
+    type: Optional[str]
+    """`disabled` or `enabled`."""

volcenginesdkarkruntime/types/responses/image_process_rotate_options.py

@@ -0,0 +1,23 @@
+# Copyright (c) [2025] [OpenAI]
+# Copyright (c) [2025] [ByteDance Ltd. and/or its affiliates.]
+# SPDX-License-Identifier: Apache-2.0
+#
+# This file has been modified by [ByteDance Ltd. and/or its affiliates.] on 2025.7
+#
+# Original file was released under Apache License Version 2.0, with the full license text
+# available at https://github.com/openai/openai-python/blob/main/LICENSE.
+#
+# This modified file is released under the same license.
+
+from __future__ import annotations
+
+from typing import Optional
+
+from ..._models import BaseModel
+
+__all__ = ["ImageProcessRotateOptions"]
+
+
+class ImageProcessRotateOptions(BaseModel):
+    type: Optional[str] = None
+    """`disabled` or `enabled`."""