Release 0.0.318

Author: fern-api[bot]

.fern/metadata.json

@@ -1,15 +1,11 @@
 {
   "cliVersion": "5.7.9",
   "generatorName": "fernapi/fern-python-sdk",
-  "generatorVersion": "5.10.0",
+  "generatorVersion": "5.3.6",
   "generatorConfig": {
     "client_class_name": "payabli",
     "enable_wire_tests": false
   },
-  "originGitCommit": "919e0fd55b82258508b2a0e599e53efa19469522",
-  "originGitCommitIsDirty": true,
-  "invokedBy": "ci",
-  "requestedVersion": "0.0.317",
-  "ciProvider": "github",
-  "sdkVersion": "0.0.317"
+  "originGitCommit": "d69946f7f37797d4fdc34de0c29dc377dbc94fc5",
+  "sdkVersion": "0.0.318"
 }

README.md

@@ -189,21 +189,11 @@ The SDK is instrumented with automatic retries with exponential backoff. A reque
 as the request is deemed retryable and the number of retry attempts has not grown larger than the configured
 retry limit (default: 2).
 
-Which status codes are retried depends on the `retryStatusCodes` generator configuration:
+A request is deemed retryable when any of the following HTTP status codes is returned:
 
-**`legacy`** (current default): retries on
 - [408](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/408) (Timeout)
-- [409](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/409) (Conflict)
 - [429](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/429) (Too Many Requests)
-- [5XX](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status#server_error_responses) (All server errors, including 500)
-
-**`recommended`**: retries on
-- [408](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/408) (Timeout)
-- [409](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/409) (Conflict)
-- [429](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/429) (Too Many Requests)
-- [502](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/502) (Bad Gateway)
-- [503](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/503) (Service Unavailable)
-- [504](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/504) (Gateway Timeout)
+- [5XX](https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/500) (Internal Server Errors)
 
 Use the `max_retries` request option to configure this behavior.
 

poetry.lock

@@ -4,7 +4,7 @@ dynamic = ["version"]
 
 [tool.poetry]
 name = "payabli"
-version = "0.0.317"
+version = "0.0.318"
 description = ""
 readme = "README.md"
 authors = []
@@ -37,21 +37,20 @@ Repository = 'https://github.com/payabli/sdk-python'
 
 [tool.poetry.dependencies]
 python = "^3.10"
-aiohttp = { version = ">=3.13.4,<4", optional = true, python = ">=3.9"}
+aiohttp = { version = ">=3.10.0,<4", optional = true}
 httpx = ">=0.21.2"
-httpx-aiohttp = { version = "0.1.8", optional = true, python = ">=3.9"}
+httpx-aiohttp = { version = "0.1.8", optional = true}
 pydantic = ">= 1.9.2"
-pydantic-core = ">=2.18.2,<3.0.0"
+pydantic-core = ">=2.18.2,<2.44.0"
 typing_extensions = ">= 4.0.0"
 
 [tool.poetry.group.dev.dependencies]
 mypy = "==1.13.0"
-pytest = "^9.0.3"
+pytest = "^8.2.0"
 pytest-asyncio = "^1.0.0"
 pytest-xdist = "^3.6.1"
 python-dateutil = "^2.9.0"
 types-python-dateutil = "^2.9.0.20240316"
-urllib3 = ">=2.6.3,<3.0.0"
 ruff = "==0.11.5"
 
 [tool.pytest.ini_options]

pyproject.toml

@@ -1,4 +1,4 @@
 httpx>=0.21.2
 pydantic>= 1.9.2
-pydantic-core>=2.18.2,<3.0.0
+pydantic-core>=2.18.2,<2.44.0
 typing_extensions>= 4.0.0

requirements.txt

@@ -27,12 +27,12 @@ def get_headers(self) -> typing.Dict[str, str]:
         import platform
 
         headers: typing.Dict[str, str] = {
-            "User-Agent": "payabli/0.0.317",
+            "User-Agent": "payabli/0.0.318",
             "X-Fern-Language": "Python",
             "X-Fern-Runtime": f"python/{platform.python_version()}",
             "X-Fern-Platform": f"{platform.system().lower()}/{platform.release()}",
             "X-Fern-SDK-Name": "payabli",
-            "X-Fern-SDK-Version": "0.0.317",
+            "X-Fern-SDK-Version": "0.0.318",
             **(self.get_custom_headers() or {}),
         }
         headers["requestToken"] = self.api_key

src/payabli/core/client_wrapper.py

@@ -125,7 +125,8 @@ def _retry_timeout_from_retries(retries: int) -> float:
 
 
 def _should_retry(response: httpx.Response) -> bool:
-    return response.status_code >= 500 or response.status_code in [429, 408, 409]
+    retryable_400s = [429, 408, 409]
+    return response.status_code >= 500 or response.status_code in retryable_400s
 
 
 _SENSITIVE_HEADERS = frozenset(

src/payabli/core/http_client.py

@@ -1,9 +1,8 @@
 # This file was auto-generated by Fern from our API Definition.
 
-import codecs
 import re
 from contextlib import asynccontextmanager, contextmanager
-from typing import Any, AsyncGenerator, AsyncIterator, Iterator
+from typing import Any, AsyncGenerator, AsyncIterator, Iterator, cast
 
 import httpx
 from ._decoders import SSEDecoder
@@ -46,81 +45,46 @@ def _get_charset(self) -> str:
     def response(self) -> httpx.Response:
         return self._response
 
-    @staticmethod
-    def _normalize_sse_line_endings(buf: str) -> str:
-        """Normalize line endings per the SSE spec (\\r\\n → \\n, bare \\r → \\n).
-
-        A trailing \\r is preserved because it may pair with a leading \\n in
-        the next chunk to form a single \\r\\n terminator.
-        """
-        buf = buf.replace("\r\n", "\n")
-        if buf.endswith("\r"):
-            return buf[:-1].replace("\r", "\n") + "\r"
-        return buf.replace("\r", "\n")
-
     def iter_sse(self) -> Iterator[ServerSentEvent]:
         self._check_content_type()
         decoder = SSEDecoder()
         charset = self._get_charset()
-        text_decoder = codecs.getincrementaldecoder(charset)(errors="replace")
 
-        buf = ""
+        buffer = ""
         for chunk in self._response.iter_bytes():
-            buf += text_decoder.decode(chunk)
-            buf = self._normalize_sse_line_endings(buf)
-
-            while "\n" in buf:
-                line, buf = buf.split("\n", 1)
+            # Decode chunk using detected charset
+            text_chunk = chunk.decode(charset, errors="replace")
+            buffer += text_chunk
+
+            # Process complete lines
+            while "\n" in buffer:
+                line, buffer = buffer.split("\n", 1)
+                line = line.rstrip("\r")
                 sse = decoder.decode(line)
+                # when we reach a "\n\n" => line = ''
+                # => decoder will attempt to return an SSE Event
                 if sse is not None:
                     yield sse
 
-        # Flush any remaining bytes from the incremental decoder
-        buf += text_decoder.decode(b"", final=True)
-        buf = buf.replace("\r\n", "\n").replace("\r", "\n")
-
-        while "\n" in buf:
-            line, buf = buf.split("\n", 1)
+        # Process any remaining data in buffer
+        if buffer.strip():
+            line = buffer.rstrip("\r")
             sse = decoder.decode(line)
             if sse is not None:
                 yield sse
 
-        if buf.strip():
-            sse = decoder.decode(buf)
-            if sse is not None:
-                yield sse
-
     async def aiter_sse(self) -> AsyncGenerator[ServerSentEvent, None]:
         self._check_content_type()
         decoder = SSEDecoder()
-        charset = self._get_charset()
-        text_decoder = codecs.getincrementaldecoder(charset)(errors="replace")
-
-        buf = ""
-        async for chunk in self._response.aiter_bytes():
-            buf += text_decoder.decode(chunk)
-            buf = self._normalize_sse_line_endings(buf)
-
-            while "\n" in buf:
-                line, buf = buf.split("\n", 1)
+        lines = cast(AsyncGenerator[str, None], self._response.aiter_lines())
+        try:
+            async for line in lines:
+                line = line.rstrip("\n")
                 sse = decoder.decode(line)
                 if sse is not None:
                     yield sse
-
-        # Flush any remaining bytes from the incremental decoder
-        buf += text_decoder.decode(b"", final=True)
-        buf = buf.replace("\r\n", "\n").replace("\r", "\n")
-
-        while "\n" in buf:
-            line, buf = buf.split("\n", 1)
-            sse = decoder.decode(line)
-            if sse is not None:
-                yield sse
-
-        if buf.strip():
-            sse = decoder.decode(buf)
-            if sse is not None:
-                yield sse
+        finally:
+            await lines.aclose()
 
 
 @contextmanager

src/payabli/core/http_sse/_api.py

@@ -10,7 +10,6 @@
     AsyncHttpClient,
     HttpClient,
     _build_url,
-    _should_retry,
     get_request_body,
     remove_none_from_dict,
 )
@@ -661,34 +660,3 @@ async def test_async_base_max_retries_used_as_default(mock_sleep: AsyncMock) ->
     assert response.status_code == 200
     # 1 initial + 3 retries = 4 total attempts
     assert mock_client.request.call_count == 4
-
-
-# ---------------------------------------------------------------------------
-# _should_retry unit tests
-# ---------------------------------------------------------------------------
-
-
-def _make_response(status_code: int) -> httpx.Response:
-    return httpx.Response(status_code=status_code, content=b"")
-
-
-@pytest.mark.parametrize(
-    "status_code",
-    [408, 409, 429, 500, 501, 502, 503, 504, 599],
-)
-def test_should_retry_retryable_status_codes(status_code: int) -> None:
-    """Legacy mode: retries on 408, 409, 429, and all >= 500."""
-    assert _should_retry(_make_response(status_code)) is True
-
-
-@pytest.mark.parametrize(
-    "status_code",
-    [200, 201, 301, 400, 401, 403, 404],
-)
-def test_should_not_retry_non_retryable_status_codes(status_code: int) -> None:
-    assert _should_retry(_make_response(status_code)) is False
-
-
-def test_should_retry_599_upper_boundary() -> None:
-    """Legacy mode retries on >= 500, which includes 599."""
-    assert _should_retry(_make_response(599)) is True