feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 16
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/reducto%2Freductoai-601f912c5d88e67d153f65a76f164ec90fbbe25335cd3714f803940d942a3b02.yml
-openapi_spec_hash: bf297fbdb7a16b1b9de02ecb34e6a779
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/reducto%2Freductoai-40a8492dc679a1650ddac779da720bf381f4a957064de8a8129b549acfe0a466.yml
+openapi_spec_hash: 0bd5676e6af83241ac9878d5d19d506d
 config_hash: 12c16025a3b7554fa6377191d68b1903

src/reducto/resources/split.py

@@ -22,6 +22,7 @@
 from ..types.split_run_job_response import SplitRunJobResponse
 from ..types.shared_params.parse_options import ParseOptions
 from ..types.shared_params.split_category import SplitCategory
+from ..types.shared_params.config_v3_async_config import ConfigV3AsyncConfig
 
 __all__ = ["SplitResource", "AsyncSplitResource"]
 
@@ -109,18 +110,40 @@ def run(
     def run_job(
         self,
         *,
-        body: object,
+        input: split_run_job_params.Input,
+        split_description: Iterable[SplitCategory],
+        async_: ConfigV3AsyncConfig | Omit = omit,
+        parsing: ParseOptions | Omit = omit,
+        settings: split_run_job_params.Settings | Omit = omit,
+        split_rules: 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,
     ) -> SplitRunJobResponse:
-        """
-        Split Async
+        """Split Async
 
         Args:
+          input: The URL of the document to be processed.
+
+        You can provide one of the
+              following: 1. A publicly available URL 2. A presigned S3 URL 3. A reducto://
+              prefixed URL obtained from the /upload endpoint after directly uploading a
+              document 4. A jobid:// prefixed URL obtained from a previous /parse invocation
+
+          split_description: The configuration options for processing the document.
+
+          async_: The configuration options for asynchronous processing (default synchronous).
+
+          parsing: The configuration options for parsing the document. If you are passing in a
+              jobid:// URL for the file, then this configuration will be ignored.
+
+          settings: The settings for split processing.
+
+          split_rules: The prompt that describes rules for splitting the document.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -131,7 +154,17 @@ def run_job(
         """
         return self._post(
             "/split_async",
-            body=maybe_transform(body, split_run_job_params.SplitRunJobParams),
+            body=maybe_transform(
+                {
+                    "input": input,
+                    "split_description": split_description,
+                    "async_": async_,
+                    "parsing": parsing,
+                    "settings": settings,
+                    "split_rules": split_rules,
+                },
+                split_run_job_params.SplitRunJobParams,
+            ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -222,18 +255,40 @@ async def run(
     async def run_job(
         self,
         *,
-        body: object,
+        input: split_run_job_params.Input,
+        split_description: Iterable[SplitCategory],
+        async_: ConfigV3AsyncConfig | Omit = omit,
+        parsing: ParseOptions | Omit = omit,
+        settings: split_run_job_params.Settings | Omit = omit,
+        split_rules: 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,
     ) -> SplitRunJobResponse:
-        """
-        Split Async
+        """Split Async
 
         Args:
+          input: The URL of the document to be processed.
+
+        You can provide one of the
+              following: 1. A publicly available URL 2. A presigned S3 URL 3. A reducto://
+              prefixed URL obtained from the /upload endpoint after directly uploading a
+              document 4. A jobid:// prefixed URL obtained from a previous /parse invocation
+
+          split_description: The configuration options for processing the document.
+
+          async_: The configuration options for asynchronous processing (default synchronous).
+
+          parsing: The configuration options for parsing the document. If you are passing in a
+              jobid:// URL for the file, then this configuration will be ignored.
+
+          settings: The settings for split processing.
+
+          split_rules: The prompt that describes rules for splitting the document.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -244,7 +299,17 @@ async def run_job(
         """
         return await self._post(
             "/split_async",
-            body=await async_maybe_transform(body, split_run_job_params.SplitRunJobParams),
+            body=await async_maybe_transform(
+                {
+                    "input": input,
+                    "split_description": split_description,
+                    "async_": async_,
+                    "parsing": parsing,
+                    "settings": settings,
+                    "split_rules": split_rules,
+                },
+                split_run_job_params.SplitRunJobParams,
+            ),
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),

src/reducto/types/split_run_job_params.py

@@ -2,10 +2,56 @@
 
 from __future__ import annotations
 
-from typing_extensions import Required, TypedDict
+from typing import Union, Iterable
+from typing_extensions import Literal, Required, Annotated, TypeAlias, TypedDict
 
-__all__ = ["SplitRunJobParams"]
+from .._utils import PropertyInfo
+from .shared_params.upload import Upload
+from .shared_params.parse_options import ParseOptions
+from .shared_params.split_category import SplitCategory
+from .shared_params.config_v3_async_config import ConfigV3AsyncConfig
+
+__all__ = ["SplitRunJobParams", "Input", "Settings"]
 
 
 class SplitRunJobParams(TypedDict, total=False):
-    body: Required[object]
+    input: Required[Input]
+    """The URL of the document to be processed.
+
+    You can provide one of the following: 1. A publicly available URL 2. A presigned
+    S3 URL 3. A reducto:// prefixed URL obtained from the /upload endpoint after
+    directly uploading a document 4. A jobid:// prefixed URL obtained from a
+    previous /parse invocation
+    """
+
+    split_description: Required[Iterable[SplitCategory]]
+    """The configuration options for processing the document."""
+
+    async_: Annotated[ConfigV3AsyncConfig, PropertyInfo(alias="async")]
+    """The configuration options for asynchronous processing (default synchronous)."""
+
+    parsing: ParseOptions
+    """The configuration options for parsing the document.
+
+    If you are passing in a jobid:// URL for the file, then this configuration will
+    be ignored.
+    """
+
+    settings: Settings
+    """The settings for split processing."""
+
+    split_rules: str
+    """The prompt that describes rules for splitting the document."""
+
+
+Input: TypeAlias = Union[str, Upload]
+
+
+class Settings(TypedDict, total=False):
+    table_cutoff: Literal["truncate", "preserve"]
+    """
+    If tables should be truncated to the first few rows or if all content should be
+    preserved. truncate improves latency, preserve is recommended for cases where
+    partition_key is being used and the partition_key may be included within the
+    table. Defaults to truncate
+    """