feat(api): manual updates

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 2
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/landingai%2Fade-f08049b74d593128128837d1e62b642bf68ee132184fddadc45d19fbc6d9f263.yml
 openapi_spec_hash: 1cf6912d5249120cb222db3890587aab
-config_hash: b5cab0bc5fca3bf0bcf2cd89cfe1b134
+config_hash: 5cb437dd50d7cfb93e1a7d70a825794e

README.md

@@ -172,9 +172,7 @@ from landingai_ade import LandingAIADE
 client = LandingAIADE()
 
 try:
-    client.extract(
-        schema="schema",
-    )
+    client.parse()
 except landingai_ade.APIConnectionError as e:
     print("The server could not be reached")
     print(e.__cause__)  # an underlying Exception, likely raised within httpx.
@@ -217,9 +215,7 @@ client = LandingAIADE(
 )
 
 # Or, configure per-request:
-client.with_options(max_retries=5).extract(
-    schema="schema",
-)
+client.with_options(max_retries=5).parse()
 ```
 
 ### Timeouts
@@ -242,9 +238,7 @@ client = LandingAIADE(
 )
 
 # Override per-request:
-client.with_options(timeout=5.0).extract(
-    schema="schema",
-)
+client.with_options(timeout=5.0).parse()
 ```
 
 On timeout, an `APITimeoutError` is thrown.
@@ -285,13 +279,11 @@ The "raw" Response object can be accessed by prefixing `.with_raw_response.` to
 from landingai_ade import LandingAIADE
 
 client = LandingAIADE()
-response = client.with_raw_response.extract(
-    schema="schema",
-)
+response = client.with_raw_response.parse()
 print(response.headers.get('X-My-Header'))
 
-client = response.parse()  # get the object that `extract()` would have returned
-print(client.extraction)
+client = response.parse()  # get the object that `parse()` would have returned
+print(client.chunks)
 ```
 
 These methods return an [`APIResponse`](https://github.com/landing-ai/ade-python/tree/main/src/landingai_ade/_response.py) object.
@@ -305,9 +297,7 @@ The above interface eagerly reads the full response body when you make the reque
 To stream the response body, use `.with_streaming_response` instead, which requires a context manager and only reads the response body once you call `.read()`, `.text()`, `.json()`, `.iter_bytes()`, `.iter_text()`, `.iter_lines()` or `.parse()`. In the async client, these are async methods.
 
 ```python
-with client.with_streaming_response.extract(
-    schema="schema",
-) as response:
+with client.with_streaming_response.parse() as response:
     print(response.headers.get("X-My-Header"))
 
     for line in response.iter_lines():

tests/test_client.py

@@ -732,20 +732,20 @@ def test_parse_retry_after_header(self, remaining_retries: int, retry_after: str
     @mock.patch("landingai_ade._base_client.BaseClient._calculate_retry_timeout", _low_retry_timeout)
     @pytest.mark.respx(base_url=base_url)
     def test_retrying_timeout_errors_doesnt_leak(self, respx_mock: MockRouter, client: LandingAIADE) -> None:
-        respx_mock.post("/v1/ade/extract").mock(side_effect=httpx.TimeoutException("Test timeout error"))
+        respx_mock.post("/v1/ade/parse").mock(side_effect=httpx.TimeoutException("Test timeout error"))
 
         with pytest.raises(APITimeoutError):
-            client.with_streaming_response.extract(schema="schema").__enter__()
+            client.with_streaming_response.parse().__enter__()
 
         assert _get_open_connections(self.client) == 0
 
     @mock.patch("landingai_ade._base_client.BaseClient._calculate_retry_timeout", _low_retry_timeout)
     @pytest.mark.respx(base_url=base_url)
     def test_retrying_status_errors_doesnt_leak(self, respx_mock: MockRouter, client: LandingAIADE) -> None:
-        respx_mock.post("/v1/ade/extract").mock(return_value=httpx.Response(500))
+        respx_mock.post("/v1/ade/parse").mock(return_value=httpx.Response(500))
 
         with pytest.raises(APIStatusError):
-            client.with_streaming_response.extract(schema="schema").__enter__()
+            client.with_streaming_response.parse().__enter__()
         assert _get_open_connections(self.client) == 0
 
     @pytest.mark.parametrize("failures_before_success", [0, 2, 4])
@@ -772,9 +772,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = client.with_raw_response.extract(schema="schema")
+        response = client.with_raw_response.parse()
 
         assert response.retries_taken == failures_before_success
         assert int(response.http_request.headers.get("x-stainless-retry-count")) == failures_before_success
@@ -796,9 +796,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = client.with_raw_response.extract(schema="schema", extra_headers={"x-stainless-retry-count": Omit()})
+        response = client.with_raw_response.parse(extra_headers={"x-stainless-retry-count": Omit()})
 
         assert len(response.http_request.headers.get_list("x-stainless-retry-count")) == 0
 
@@ -819,9 +819,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = client.with_raw_response.extract(schema="schema", extra_headers={"x-stainless-retry-count": "42"})
+        response = client.with_raw_response.parse(extra_headers={"x-stainless-retry-count": "42"})
 
         assert response.http_request.headers.get("x-stainless-retry-count") == "42"
 
@@ -1559,10 +1559,10 @@ async def test_parse_retry_after_header(self, remaining_retries: int, retry_afte
     async def test_retrying_timeout_errors_doesnt_leak(
         self, respx_mock: MockRouter, async_client: AsyncLandingAIADE
     ) -> None:
-        respx_mock.post("/v1/ade/extract").mock(side_effect=httpx.TimeoutException("Test timeout error"))
+        respx_mock.post("/v1/ade/parse").mock(side_effect=httpx.TimeoutException("Test timeout error"))
 
         with pytest.raises(APITimeoutError):
-            await async_client.with_streaming_response.extract(schema="schema").__aenter__()
+            await async_client.with_streaming_response.parse().__aenter__()
 
         assert _get_open_connections(self.client) == 0
 
@@ -1571,10 +1571,10 @@ async def test_retrying_timeout_errors_doesnt_leak(
     async def test_retrying_status_errors_doesnt_leak(
         self, respx_mock: MockRouter, async_client: AsyncLandingAIADE
     ) -> None:
-        respx_mock.post("/v1/ade/extract").mock(return_value=httpx.Response(500))
+        respx_mock.post("/v1/ade/parse").mock(return_value=httpx.Response(500))
 
         with pytest.raises(APIStatusError):
-            await async_client.with_streaming_response.extract(schema="schema").__aenter__()
+            await async_client.with_streaming_response.parse().__aenter__()
         assert _get_open_connections(self.client) == 0
 
     @pytest.mark.parametrize("failures_before_success", [0, 2, 4])
@@ -1602,9 +1602,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = await client.with_raw_response.extract(schema="schema")
+        response = await client.with_raw_response.parse()
 
         assert response.retries_taken == failures_before_success
         assert int(response.http_request.headers.get("x-stainless-retry-count")) == failures_before_success
@@ -1627,11 +1627,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = await client.with_raw_response.extract(
-            schema="schema", extra_headers={"x-stainless-retry-count": Omit()}
-        )
+        response = await client.with_raw_response.parse(extra_headers={"x-stainless-retry-count": Omit()})
 
         assert len(response.http_request.headers.get_list("x-stainless-retry-count")) == 0
 
@@ -1653,11 +1651,9 @@ def retry_handler(_request: httpx.Request) -> httpx.Response:
                 return httpx.Response(500)
             return httpx.Response(200)
 
-        respx_mock.post("/v1/ade/extract").mock(side_effect=retry_handler)
+        respx_mock.post("/v1/ade/parse").mock(side_effect=retry_handler)
 
-        response = await client.with_raw_response.extract(
-            schema="schema", extra_headers={"x-stainless-retry-count": "42"}
-        )
+        response = await client.with_raw_response.parse(extra_headers={"x-stainless-retry-count": "42"})
 
         assert response.http_request.headers.get("x-stainless-retry-count") == "42"