release: 1.1.0 (#57)

* codegen metadata

* fix: ensure streams are always closed

* chore(deps): mypy 1.18.1 has a regression, pin to 1.17

* feat(api): manual updates

* release: 1.1.0

---------

Co-authored-by: stainless-app[bot] <142633134+stainless-app[bot]@users.noreply.github.com>

Author: stainless-app[bot]

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "1.0.0"
+  ".": "1.1.0"
 }

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 5
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/landingai%2Fade-5fd0d575b1a6fa494b29ccaadb9e17d22bbf11b82fc989046a7918bbe724d580.yml
-openapi_spec_hash: 27311a7b73611acc010ad87e18f18650
-config_hash: caa107af314426538518ba625510805f
+configured_endpoints: 6
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/landingai%2Fade-b3f2ee0a1bc9c8c3d6f1bb4a50621c75ee98344774c3237637eef178291d8461.yml
+openapi_spec_hash: 24efc4d96b54caebcdf4445d319693ae
+config_hash: 43f45ffa1cb556d90dcef6d742ed239f

CHANGELOG.md

@@ -1,5 +1,23 @@
 # Changelog
 
+## 1.1.0 (2025-12-02)
+
+Full Changelog: [v1.0.0...v1.1.0](https://github.com/landing-ai/ade-python/compare/v1.0.0...v1.1.0)
+
+### Features
+
+* **api:** manual updates ([a2c622d](https://github.com/landing-ai/ade-python/commit/a2c622db797caf02fc38e8e10ec841793b545032))
+
+
+### Bug Fixes
+
+* ensure streams are always closed ([c903098](https://github.com/landing-ai/ade-python/commit/c90309862771f208c24df5bb7a570769821d1a7a))
+
+
+### Chores
+
+* **deps:** mypy 1.18.1 has a regression, pin to 1.17 ([a768a1c](https://github.com/landing-ai/ade-python/commit/a768a1c1cf8953a48c25712e293f49bee98494dc))
+
 ## 1.0.0 (2025-11-22)
 
 Full Changelog: [v0.21.2...v1.0.0](https://github.com/landing-ai/ade-python/compare/v0.21.2...v1.0.0)

api.md

@@ -9,13 +9,14 @@ from landingai_ade.types import ParseGroundingBox, ParseMetadata
 Types:
 
 ```python
-from landingai_ade.types import ExtractResponse, ParseResponse
+from landingai_ade.types import ExtractResponse, ParseResponse, SplitResponse
 ```
 
 Methods:
 
 - <code title="post /v1/ade/extract">client.<a href="./src/landingai_ade/_client.py">extract</a>(\*\*<a href="src/landingai_ade/types/client_extract_params.py">params</a>) -> <a href="./src/landingai_ade/types/extract_response.py">ExtractResponse</a></code>
 - <code title="post /v1/ade/parse">client.<a href="./src/landingai_ade/_client.py">parse</a>(\*\*<a href="src/landingai_ade/types/client_parse_params.py">params</a>) -> <a href="./src/landingai_ade/types/parse_response.py">ParseResponse</a></code>
+- <code title="post /v1/ade/split">client.<a href="./src/landingai_ade/_client.py">split</a>(\*\*<a href="src/landingai_ade/types/client_split_params.py">params</a>) -> <a href="./src/landingai_ade/types/split_response.py">SplitResponse</a></code>
 
 # ParseJobs
 

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "landingai-ade"
-version = "1.0.0"
+version = "1.1.0"
 description = "The official Python library for the landingai-ade API"
 dynamic = ["readme"]
 license = "Apache-2.0"
@@ -46,7 +46,7 @@ managed = true
 # version pins are in requirements-dev.lock
 dev-dependencies = [
     "pyright==1.1.399",
-    "mypy",
+    "mypy==1.17",
     "respx",
     "pytest",
     "pytest-asyncio",

requirements-dev.lock

@@ -72,7 +72,7 @@ mdurl==0.1.2
 multidict==6.4.4
     # via aiohttp
     # via yarl
-mypy==1.14.1
+mypy==1.17.0
 mypy-extensions==1.0.0
     # via mypy
 nodeenv==1.8.0
@@ -81,6 +81,8 @@ nox==2023.4.22
 packaging==23.2
     # via nox
     # via pytest
+pathspec==0.12.1
+    # via mypy
 platformdirs==3.11.0
     # via virtualenv
 pluggy==1.5.0

requirements.lock

@@ -55,21 +55,21 @@ multidict==6.4.4
 propcache==0.3.1
     # via aiohttp
     # via yarl
-pydantic==2.11.9
+pydantic==2.12.5
     # via landingai-ade
-pydantic-core==2.33.2
+pydantic-core==2.41.5
     # via pydantic
 sniffio==1.3.0
     # via anyio
     # via landingai-ade
-typing-extensions==4.12.2
+typing-extensions==4.15.0
     # via anyio
     # via landingai-ade
     # via multidict
     # via pydantic
     # via pydantic-core
     # via typing-inspection
-typing-inspection==0.4.1
+typing-inspection==0.4.2
     # via pydantic
 yarl==1.20.0
     # via aiohttp

src/landingai_ade/_client.py

@@ -4,14 +4,14 @@
 
 import os
 import importlib.metadata
-from typing import Any, Dict, Mapping, Optional, cast
+from typing import Any, Dict, Mapping, Iterable, Optional, cast
 from typing_extensions import Self, Literal, override
 
 import httpx
 
 from . import _exceptions
 from ._qs import Querystring
-from .types import client_parse_params, client_extract_params
+from .types import client_parse_params, client_split_params, client_extract_params
 from ._types import (
     Body,
     Omit,
@@ -52,6 +52,7 @@
 )
 from .lib.url_utils import convert_url_to_file_if_local
 from .types.parse_response import ParseResponse
+from .types.split_response import SplitResponse
 from .types.extract_response import ExtractResponse
 
 _LIB_VERSION = importlib.metadata.version("landingai-ade")
@@ -391,6 +392,71 @@ def parse(
             cast_to=ParseResponse,
         )
 
+    def split(
+        self,
+        *,
+        options: Iterable[client_split_params.Option],
+        markdown: Optional[FileTypes] | Omit = omit,
+        markdown_url: Optional[str] | Omit = omit,
+        model: Optional[str] | Omit = omit,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> SplitResponse:
+        """
+        Split classification for documents.
+
+        This endpoint classifies document sections based on markdown content and split
+        options.
+
+        For EU users, use this endpoint:
+
+            `https://api.va.eu-west-1.landing.ai/v1/ade/split`.
+
+        Args:
+          options: List of split classification options/configuration. Can be provided as JSON
+              string in form data.
+
+          markdown: The Markdown file or Markdown content to split.
+
+          markdown_url: The URL to the Markdown file to split.
+
+          model: Model version to use for split classification. Defaults to the latest version.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        body = deepcopy_minimal(
+            {
+                "options": options,
+                "markdown": markdown,
+                "markdown_url": markdown_url,
+                "model": model,
+            }
+        )
+        files = extract_files(cast(Mapping[str, object], body), paths=[["markdown"]])
+        # It should be noted that the actual Content-Type header that will be
+        # sent to the server will contain a `boundary` parameter, e.g.
+        # multipart/form-data; boundary=---abc--
+        extra_headers = {"Content-Type": "multipart/form-data", **(extra_headers or {})}
+        return self.post(
+            "/v1/ade/split",
+            body=maybe_transform(body, client_split_params.ClientSplitParams),
+            files=files,
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=SplitResponse,
+        )
+
     @override
     def _make_status_error(
         self,
@@ -742,6 +808,71 @@ async def parse(
             cast_to=ParseResponse,
         )
 
+    async def split(
+        self,
+        *,
+        options: Iterable[client_split_params.Option],
+        markdown: Optional[FileTypes] | Omit = omit,
+        markdown_url: Optional[str] | Omit = omit,
+        model: Optional[str] | Omit = omit,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = not_given,
+    ) -> SplitResponse:
+        """
+        Split classification for documents.
+
+        This endpoint classifies document sections based on markdown content and split
+        options.
+
+        For EU users, use this endpoint:
+
+            `https://api.va.eu-west-1.landing.ai/v1/ade/split`.
+
+        Args:
+          options: List of split classification options/configuration. Can be provided as JSON
+              string in form data.
+
+          markdown: The Markdown file or Markdown content to split.
+
+          markdown_url: The URL to the Markdown file to split.
+
+          model: Model version to use for split classification. Defaults to the latest version.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        body = deepcopy_minimal(
+            {
+                "options": options,
+                "markdown": markdown,
+                "markdown_url": markdown_url,
+                "model": model,
+            }
+        )
+        files = extract_files(cast(Mapping[str, object], body), paths=[["markdown"]])
+        # It should be noted that the actual Content-Type header that will be
+        # sent to the server will contain a `boundary` parameter, e.g.
+        # multipart/form-data; boundary=---abc--
+        extra_headers = {"Content-Type": "multipart/form-data", **(extra_headers or {})}
+        return await self.post(
+            "/v1/ade/split",
+            body=await async_maybe_transform(body, client_split_params.ClientSplitParams),
+            files=files,
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=SplitResponse,
+        )
+
     @override
     def _make_status_error(
         self,
@@ -786,6 +917,9 @@ def __init__(self, client: LandingAIADE) -> None:
         self.parse = to_raw_response_wrapper(
             client.parse,
         )
+        self.split = to_raw_response_wrapper(
+            client.split,
+        )
 
 
 class AsyncLandingAIADEWithRawResponse:
@@ -798,6 +932,9 @@ def __init__(self, client: AsyncLandingAIADE) -> None:
         self.parse = async_to_raw_response_wrapper(
             client.parse,
         )
+        self.split = async_to_raw_response_wrapper(
+            client.split,
+        )
 
 
 class LandingAIADEWithStreamedResponse:
@@ -810,6 +947,9 @@ def __init__(self, client: LandingAIADE) -> None:
         self.parse = to_streamed_response_wrapper(
             client.parse,
         )
+        self.split = to_streamed_response_wrapper(
+            client.split,
+        )
 
 
 class AsyncLandingAIADEWithStreamedResponse:
@@ -822,6 +962,9 @@ def __init__(self, client: AsyncLandingAIADE) -> None:
         self.parse = async_to_streamed_response_wrapper(
             client.parse,
         )
+        self.split = async_to_streamed_response_wrapper(
+            client.split,
+        )
 
 
 Client = LandingAIADE

src/landingai_ade/_streaming.py

@@ -54,11 +54,12 @@ def __stream__(self) -> Iterator[_T]:
         process_data = self._client._process_response_data
         iterator = self._iter_events()
 
-        for sse in iterator:
-            yield process_data(data=sse.json(), cast_to=cast_to, response=response)
-
-        # As we might not fully consume the response stream, we need to close it explicitly
-        response.close()
+        try:
+            for sse in iterator:
+                yield process_data(data=sse.json(), cast_to=cast_to, response=response)
+        finally:
+            # Ensure the response is closed even if the consumer doesn't read all data
+            response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -117,11 +118,12 @@ async def __stream__(self) -> AsyncIterator[_T]:
         process_data = self._client._process_response_data
         iterator = self._iter_events()
 
-        async for sse in iterator:
-            yield process_data(data=sse.json(), cast_to=cast_to, response=response)
-
-        # As we might not fully consume the response stream, we need to close it explicitly
-        await response.aclose()
+        try:
+            async for sse in iterator:
+                yield process_data(data=sse.json(), cast_to=cast_to, response=response)
+        finally:
+            # Ensure the response is closed even if the consumer doesn't read all data
+            await response.aclose()
 
     async def __aenter__(self) -> Self:
         return self

src/landingai_ade/_version.py

@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "landingai_ade"
-__version__ = "1.0.0"  # x-release-please-version
+__version__ = "1.1.0"  # x-release-please-version