feat(*): support ark batch chat

Author: jizhongBao

volcenginesdkarkruntime/_base_client.py

@@ -478,57 +478,6 @@ def _request(
             stream_cls=stream_cls,
         )
 
-    def _request_without_retry(self,
-            *,
-            cast_to: Type[ResponseT],
-            options: RequestOptions,
-            stream: bool,
-            stream_cls: type[_StreamT] | None,
-    ) -> ResponseT | _StreamT:
-        request = self._build_request(options)
-        req_id = request.headers.get(CLIENT_REQUEST_HEADER, "")
-        try:
-            response = self._client.send(
-                request,
-                stream=stream or self._should_stream_response_body(request=request),
-            )
-        except httpx.TimeoutException as err:
-            log.debug("Raising timeout error")
-            raise ArkAPITimeoutError(request=request, request_id=req_id) from err
-        except Exception as err:
-            log.debug("Encountered Exception", exc_info=True)
-            log.debug("Raising connection error")
-            raise ArkAPIConnectionError(request=request, request_id=req_id) from err
-
-        log.debug(
-            'HTTP Request: %s %s "%i %s"',
-            request.method,
-            request.url,
-            response.status_code,
-            response.reason_phrase,
-        )
-
-        try:
-            response.raise_for_status()
-        except httpx.HTTPStatusError as err:  # thrown on 4xx and 5xx status code
-            log.debug("Encountered httpx.HTTPStatusError", exc_info=True)
-            # If the response is streamed then we need to explicitly read the response
-            # to completion before attempting to access the response text.
-            if not err.response.is_closed:
-                err.response.read()
-
-            log.debug("Re-raising status error")
-            raise self._make_status_error_from_response(
-                err.response, request_id=req_id
-            ) from None
-
-        return self._process_response(
-            cast_to=cast_to,
-            response=response,
-            stream=stream,
-            stream_cls=stream_cls,
-        )
-
     def _retry_request(
             self,
             options: RequestOptions,
@@ -665,7 +614,7 @@ def post_without_retry(
         )
 
         return cast(
-            ResponseT, self.request_without_retry(cast_to, opts, stream=stream, stream_cls=stream_cls)
+            ResponseT, self.request(cast_to, opts, remaining_retries=0, stream=stream, stream_cls=stream_cls)
         )
 
     def request(
@@ -685,21 +634,6 @@ def request(
             remaining_retries=remaining_retries,
         )
 
-    def request_without_retry(
-            self,
-            cast_to: Type[ResponseT],
-            options: RequestOptions,
-            *,
-            stream: bool = False,
-            stream_cls: type[_StreamT] | None = None,
-    ) -> ResponseT | _StreamT:
-        return self._request_without_retry(
-            cast_to=cast_to,
-            options=options,
-            stream=stream,
-            stream_cls=stream_cls,
-        )
-
     def is_closed(self) -> bool:
         return self._client.is_closed
 
@@ -861,7 +795,7 @@ async def post_without_retry(
             **options,
         )
 
-        return await self.request_without_retry(cast_to, opts, stream=stream, stream_cls=stream_cls)
+        return await self.request(cast_to, opts, remaining_retries=0, stream=stream, stream_cls=stream_cls)
 
     async def request(
             self,
@@ -880,21 +814,6 @@ async def request(
             remaining_retries=remaining_retries,
         )
 
-    async def request_without_retry(
-            self,
-            cast_to: Type[ResponseT],
-            options: RequestOptions,
-            *,
-            stream: bool = False,
-            stream_cls: type[_StreamT] | None = None,
-    ) -> ResponseT | _StreamT:
-        return await self._request_without_retry(
-            cast_to=cast_to,
-            options=options,
-            stream=stream,
-            stream_cls=stream_cls,
-        )
-
     async def _request(
             self,
             *,
@@ -982,57 +901,6 @@ async def _request(
             stream_cls=stream_cls,
         )
 
-    async def _request_without_retry(
-            self,
-            *,
-            cast_to: Type[ResponseT],
-            options: RequestOptions,
-            stream: bool,
-            stream_cls: type[_AsyncStreamT] | None,
-    ) -> ResponseT | _AsyncStreamT:
-        request = self._build_request(options)
-        req_id = request.headers.get(CLIENT_REQUEST_HEADER, "")
-        try:
-            response = await self._client.send(
-                request,
-                stream=stream or self._should_stream_response_body(request=request),
-            )
-        except httpx.TimeoutException as err:
-            log.debug("Raising timeout error")
-            raise ArkAPITimeoutError(request=request, request_id=req_id) from err
-        except Exception as err:
-            log.debug("Encountered Exception", exc_info=True)
-            log.debug("Raising connection error")
-            raise ArkAPIConnectionError(request=request, request_id=req_id) from err
-        log.debug(
-            'HTTP Request: %s %s "%i %s"',
-            request.method,
-            request.url,
-            response.status_code,
-            response.reason_phrase,
-        )
-        try:
-            response.raise_for_status()
-        except httpx.HTTPStatusError as err:  # thrown on 4xx and 5xx status code
-            log.debug("Encountered httpx.HTTPStatusError", exc_info=True)
-
-            # If the response is streamed then we need to explicitly read the response
-            # to completion before attempting to access the response text.
-            if not err.response.is_closed:
-                await err.response.aread()
-
-            log.debug("Re-raising status error")
-            raise self._make_status_error_from_response(
-                err.response, request_id=req_id
-            ) from None
-
-        return await self._process_response(
-            cast_to=cast_to,
-            response=response,
-            stream=stream,
-            stream_cls=stream_cls,
-        )
-
     async def _retry_request(
             self,
             options: RequestOptions,