chore(internal): codegen related update (#290)

Author: stainless-app[bot]

README.md

@@ -54,8 +54,10 @@ client = AsyncOnebusawaySDK(
     api_key=os.environ.get("ONEBUSAWAY_API_KEY"),  # This is the default and can be omitted
 )
 
+
 async def main() -> None:
-  current_time = await client.current_time.retrieve()
+    current_time = await client.current_time.retrieve()
+
 
 asyncio.run(main())
 ```
@@ -90,7 +92,7 @@ try:
     client.current_time.retrieve()
 except onebusaway.APIConnectionError as e:
     print("The server could not be reached")
-    print(e.__cause__) # an underlying Exception, likely raised within httpx.
+    print(e.__cause__)  # an underlying Exception, likely raised within httpx.
 except onebusaway.RateLimitError as e:
     print("A 429 status code was received; we should back off a bit.")
 except onebusaway.APIStatusError as e:
@@ -130,7 +132,7 @@ client = OnebusawaySDK(
 )
 
 # Or, configure per-request:
-client.with_options(max_retries = 5).current_time.retrieve()
+client.with_options(max_retries=5).current_time.retrieve()
 ```
 
 ### Timeouts
@@ -153,7 +155,7 @@ client = OnebusawaySDK(
 )
 
 # Override per-request:
-client.with_options(timeout = 5.0).current_time.retrieve()
+client.with_options(timeout=5.0).current_time.retrieve()
 ```
 
 On timeout, an `APITimeoutError` is thrown.
@@ -212,11 +214,11 @@ 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.current_time.with_streaming_response.retrieve() as response :
-    print(response.headers.get('X-My-Header'))
+with client.current_time.with_streaming_response.retrieve() as response:
+    print(response.headers.get("X-My-Header"))
 
     for line in response.iter_lines():
-      print(line)
+        print(line)
 ```
 
 The context manager is required so that the response will reliably be closed.
@@ -270,7 +272,10 @@ from onebusaway import OnebusawaySDK, DefaultHttpxClient
 client = OnebusawaySDK(
     # Or use the `ONEBUSAWAY_SDK_BASE_URL` env var
     base_url="http://my.test.server.example.com:8083",
-    http_client=DefaultHttpxClient(proxy="http://my.test.proxy.example.com", transport=httpx.HTTPTransport(local_address="0.0.0.0")),
+    http_client=DefaultHttpxClient(
+        proxy="http://my.test.proxy.example.com",
+        transport=httpx.HTTPTransport(local_address="0.0.0.0"),
+    ),
 )
 ```
 

requirements-dev.lock

@@ -14,7 +14,7 @@ annotated-types==0.6.0
     # via pydantic
 anyio==4.4.0
     # via httpx
-    # via sdk-pythonpackagename
+    # via onebusaway
 argcomplete==3.1.2
     # via nox
 certifi==2023.7.22
@@ -26,7 +26,7 @@ dirty-equals==0.6.0
 distlib==0.3.7
     # via virtualenv
 distro==1.8.0
-    # via sdk-pythonpackagename
+    # via onebusaway
 exceptiongroup==1.2.2
     # via anyio
     # via pytest
@@ -37,8 +37,8 @@ h11==0.14.0
 httpcore==1.0.2
     # via httpx
 httpx==0.28.1
+    # via onebusaway
     # via respx
-    # via sdk-pythonpackagename
 idna==3.4
     # via anyio
     # via httpx
@@ -64,7 +64,7 @@ platformdirs==3.11.0
 pluggy==1.5.0
     # via pytest
 pydantic==2.10.3
-    # via sdk-pythonpackagename
+    # via onebusaway
 pydantic-core==2.27.1
     # via pydantic
 pygments==2.18.0
@@ -86,18 +86,18 @@ six==1.16.0
     # via python-dateutil
 sniffio==1.3.0
     # via anyio
-    # via sdk-pythonpackagename
+    # via onebusaway
 time-machine==2.9.0
 tomli==2.0.2
     # via mypy
     # via pytest
 typing-extensions==4.12.2
     # via anyio
     # via mypy
+    # via onebusaway
     # via pydantic
     # via pydantic-core
     # via pyright
-    # via sdk-pythonpackagename
 virtualenv==20.24.5
     # via nox
 zipp==3.17.0

requirements.lock

@@ -14,32 +14,32 @@ annotated-types==0.6.0
     # via pydantic
 anyio==4.4.0
     # via httpx
-    # via sdk-pythonpackagename
+    # via onebusaway
 certifi==2023.7.22
     # via httpcore
     # via httpx
 distro==1.8.0
-    # via sdk-pythonpackagename
+    # via onebusaway
 exceptiongroup==1.2.2
     # via anyio
 h11==0.14.0
     # via httpcore
 httpcore==1.0.2
     # via httpx
 httpx==0.28.1
-    # via sdk-pythonpackagename
+    # via onebusaway
 idna==3.4
     # via anyio
     # via httpx
 pydantic==2.10.3
-    # via sdk-pythonpackagename
+    # via onebusaway
 pydantic-core==2.27.1
     # via pydantic
 sniffio==1.3.0
     # via anyio
-    # via sdk-pythonpackagename
+    # via onebusaway
 typing-extensions==4.12.2
     # via anyio
+    # via onebusaway
     # via pydantic
     # via pydantic-core
-    # via sdk-pythonpackagename

scripts/utils/ruffen-docs.py

@@ -47,7 +47,7 @@ def _md_match(match: Match[str]) -> str:
         with _collect_error(match):
             code = format_code_block(code)
         code = textwrap.indent(code, match["indent"])
-        return f'{match["before"]}{code}{match["after"]}'
+        return f"{match['before']}{code}{match['after']}"
 
     def _pycon_match(match: Match[str]) -> str:
         code = ""
@@ -97,7 +97,7 @@ def finish_fragment() -> None:
     def _md_pycon_match(match: Match[str]) -> str:
         code = _pycon_match(match)
         code = textwrap.indent(code, match["indent"])
-        return f'{match["before"]}{code}{match["after"]}'
+        return f"{match['before']}{code}{match['after']}"
 
     src = MD_RE.sub(_md_match, src)
     src = MD_PYCON_RE.sub(_md_pycon_match, src)

src/onebusaway/__init__.py

@@ -37,7 +37,46 @@
 from ._base_client import DefaultHttpxClient, DefaultAsyncHttpxClient
 from ._utils._logs import setup_logging as _setup_logging
 
-__all__ = ["types", "__version__", "__title__", "NoneType", "Transport", "ProxiesTypes", "NotGiven", "NOT_GIVEN", "Omit", "OnebusawaySDKError", "APIError", "APIStatusError", "APITimeoutError", "APIConnectionError", "APIResponseValidationError", "BadRequestError", "AuthenticationError", "PermissionDeniedError", "NotFoundError", "ConflictError", "UnprocessableEntityError", "RateLimitError", "InternalServerError", "Timeout", "RequestOptions", "Client", "AsyncClient", "Stream", "AsyncStream", "OnebusawaySDK", "AsyncOnebusawaySDK", "file_from_path", "BaseModel", "DEFAULT_TIMEOUT", "DEFAULT_MAX_RETRIES", "DEFAULT_CONNECTION_LIMITS", "DefaultHttpxClient", "DefaultAsyncHttpxClient"]
+__all__ = [
+    "types",
+    "__version__",
+    "__title__",
+    "NoneType",
+    "Transport",
+    "ProxiesTypes",
+    "NotGiven",
+    "NOT_GIVEN",
+    "Omit",
+    "OnebusawaySDKError",
+    "APIError",
+    "APIStatusError",
+    "APITimeoutError",
+    "APIConnectionError",
+    "APIResponseValidationError",
+    "BadRequestError",
+    "AuthenticationError",
+    "PermissionDeniedError",
+    "NotFoundError",
+    "ConflictError",
+    "UnprocessableEntityError",
+    "RateLimitError",
+    "InternalServerError",
+    "Timeout",
+    "RequestOptions",
+    "Client",
+    "AsyncClient",
+    "Stream",
+    "AsyncStream",
+    "OnebusawaySDK",
+    "AsyncOnebusawaySDK",
+    "file_from_path",
+    "BaseModel",
+    "DEFAULT_TIMEOUT",
+    "DEFAULT_MAX_RETRIES",
+    "DEFAULT_CONNECTION_LIMITS",
+    "DefaultHttpxClient",
+    "DefaultAsyncHttpxClient",
+]
 
 _setup_logging()
 
@@ -52,4 +91,4 @@
            __locals[__name].__module__ = "onebusaway"
         except (TypeError, AttributeError):
             # Some of our exported symbols are builtins which we can't set attributes for.
-            pass
+            pass

src/onebusaway/_base_client.py

@@ -203,7 +203,7 @@ def _set_private_attributes(
         model: Type[_T],
         options: FinalRequestOptions,
     ) -> None:
-        if PYDANTIC_V2 and getattr(self, '__pydantic_private__', None) is None:
+        if PYDANTIC_V2 and getattr(self, "__pydantic_private__", None) is None:
             self.__pydantic_private__ = {}
 
         self._model = model
@@ -291,7 +291,7 @@ def _set_private_attributes(
         client: AsyncAPIClient,
         options: FinalRequestOptions,
     ) -> None:
-        if PYDANTIC_V2 and getattr(self, '__pydantic_private__', None) is None:
+        if PYDANTIC_V2 and getattr(self, "__pydantic_private__", None) is None:
             self.__pydantic_private__ = {}
 
         self._model = model
@@ -608,7 +608,7 @@ def default_headers(self) -> dict[str, str | Omit]:
             "Accept": "application/json",
             "Content-Type": "application/json",
             "User-Agent": self.user_agent,
-**self.platform_headers(),
+            **self.platform_headers(),
             **self.auth_headers,
             **self._custom_headers,
         }
@@ -994,7 +994,6 @@ def _request(
             response.reason_phrase,
             response.headers,
         )
-        
 
         try:
             response.raise_for_status()
@@ -1070,8 +1069,6 @@ def _process_response(
         stream_cls: type[Stream[Any]] | type[AsyncStream[Any]] | None,
         retries_taken: int = 0,
     ) -> ResponseT:
-        
-
         origin = get_origin(cast_to) or cast_to
 
         if inspect.isclass(origin) and issubclass(origin, BaseAPIResponse):
@@ -1595,8 +1592,6 @@ async def _process_response(
         stream_cls: type[Stream[Any]] | type[AsyncStream[Any]] | None,
         retries_taken: int = 0,
     ) -> ResponseT:
-        
-
         origin = get_origin(cast_to) or cast_to
 
         if inspect.isclass(origin) and issubclass(origin, BaseAPIResponse):