feat(api): update via SDK Studio

Author: stainless-bot

.github/workflows/ci.yml

@@ -6,6 +6,7 @@ on:
   pull_request:
     branches:
       - main
+      - next
 
 jobs:
   lint:

.stats.yml

@@ -1,2 +1,2 @@
-configured_endpoints: 11
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/open-transit%2Fopen-transit-c1ea5e90257369e139272db8e69752724a4c2ba2a4fc1a2df99b1f744fedd05f.yml
+configured_endpoints: 12
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/open-transit%2Fopen-transit-d7feb31fedeae9f0af2581bf85d95d374eb2eee635e6823975bc4f419bd8e492.yml

api.md

@@ -124,3 +124,15 @@ from onebusaway.types import TripsForLocationRetrieveResponse
 Methods:
 
 - <code title="get /api/where/trips-for-location.json">client.trips_for_location.<a href="./src/onebusaway/resources/trips_for_location.py">retrieve</a>(\*\*<a href="src/onebusaway/types/trips_for_location_retrieve_params.py">params</a>) -> <a href="./src/onebusaway/types/trips_for_location_retrieve_response.py">TripsForLocationRetrieveResponse</a></code>
+
+# TripDetails
+
+Types:
+
+```python
+from onebusaway.types import TripDetailRetrieveResponse
+```
+
+Methods:
+
+- <code title="get /api/where/trip-details/{tripID}.json">client.trip_details.<a href="./src/onebusaway/resources/trip_details.py">retrieve</a>(trip_id, \*\*<a href="src/onebusaway/types/trip_detail_retrieve_params.py">params</a>) -> <a href="./src/onebusaway/types/trip_detail_retrieve_response.py">TripDetailRetrieveResponse</a></code>

requirements-dev.lock

@@ -49,7 +49,7 @@ markdown-it-py==3.0.0
     # via rich
 mdurl==0.1.2
     # via markdown-it-py
-mypy==1.7.1
+mypy==1.10.1
 mypy-extensions==1.0.0
     # via mypy
 nodeenv==1.8.0

src/onebusaway/_base_client.py

@@ -955,6 +955,11 @@ def _request(
         stream: bool,
         stream_cls: type[_StreamT] | None,
     ) -> ResponseT | _StreamT:
+        # create a copy of the options we were given so that if the
+        # options are mutated later & we then retry, the retries are
+        # given the original options
+        input_options = model_copy(options)
+
         cast_to = self._maybe_override_cast_to(cast_to, options)
         self._prepare_options(options)
 
@@ -979,7 +984,7 @@ def _request(
 
             if retries > 0:
                 return self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     stream=stream,
@@ -994,7 +999,7 @@ def _request(
 
             if retries > 0:
                 return self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     stream=stream,
@@ -1022,7 +1027,7 @@ def _request(
             if retries > 0 and self._should_retry(err.response):
                 err.response.close()
                 return self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     err.response.headers,
@@ -1518,6 +1523,11 @@ async def _request(
             # execute it earlier while we are in an async context
             self._platform = await asyncify(get_platform)()
 
+        # create a copy of the options we were given so that if the
+        # options are mutated later & we then retry, the retries are
+        # given the original options
+        input_options = model_copy(options)
+
         cast_to = self._maybe_override_cast_to(cast_to, options)
         await self._prepare_options(options)
 
@@ -1540,7 +1550,7 @@ async def _request(
 
             if retries > 0:
                 return await self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     stream=stream,
@@ -1555,7 +1565,7 @@ async def _request(
 
             if retries > 0:
                 return await self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     stream=stream,
@@ -1578,7 +1588,7 @@ async def _request(
             if retries > 0 and self._should_retry(err.response):
                 await err.response.aclose()
                 return await self._retry_request(
-                    options,
+                    input_options,
                     cast_to,
                     retries,
                     err.response.headers,

src/onebusaway/_client.py

@@ -56,6 +56,7 @@ class OnebusawaySDK(SyncAPIClient):
     arrival_and_departure: resources.ArrivalAndDepartureResource
     trip: resources.TripResource
     trips_for_location: resources.TripsForLocationResource
+    trip_details: resources.TripDetailsResource
     with_raw_response: OnebusawaySDKWithRawResponse
     with_streaming_response: OnebusawaySDKWithStreamedResponse
 
@@ -123,6 +124,7 @@ def __init__(
         self.arrival_and_departure = resources.ArrivalAndDepartureResource(self)
         self.trip = resources.TripResource(self)
         self.trips_for_location = resources.TripsForLocationResource(self)
+        self.trip_details = resources.TripDetailsResource(self)
         self.with_raw_response = OnebusawaySDKWithRawResponse(self)
         self.with_streaming_response = OnebusawaySDKWithStreamedResponse(self)
 
@@ -132,9 +134,8 @@ def qs(self) -> Querystring:
         return Querystring(array_format="repeat")
 
     @property
-    @override
-    def auth_headers(self) -> dict[str, str]:
-        return {}
+    def auth_headers(self) -> httpx.Auth:
+        raise NotImplementedError("This auth method has not been implemented yet.")
 
     @property
     @override
@@ -250,6 +251,7 @@ class AsyncOnebusawaySDK(AsyncAPIClient):
     arrival_and_departure: resources.AsyncArrivalAndDepartureResource
     trip: resources.AsyncTripResource
     trips_for_location: resources.AsyncTripsForLocationResource
+    trip_details: resources.AsyncTripDetailsResource
     with_raw_response: AsyncOnebusawaySDKWithRawResponse
     with_streaming_response: AsyncOnebusawaySDKWithStreamedResponse
 
@@ -317,6 +319,7 @@ def __init__(
         self.arrival_and_departure = resources.AsyncArrivalAndDepartureResource(self)
         self.trip = resources.AsyncTripResource(self)
         self.trips_for_location = resources.AsyncTripsForLocationResource(self)
+        self.trip_details = resources.AsyncTripDetailsResource(self)
         self.with_raw_response = AsyncOnebusawaySDKWithRawResponse(self)
         self.with_streaming_response = AsyncOnebusawaySDKWithStreamedResponse(self)
 
@@ -326,9 +329,8 @@ def qs(self) -> Querystring:
         return Querystring(array_format="repeat")
 
     @property
-    @override
-    def auth_headers(self) -> dict[str, str]:
-        return {}
+    def auth_headers(self) -> httpx.Auth:
+        raise NotImplementedError("This auth method has not been implemented yet.")
 
     @property
     @override
@@ -447,6 +449,7 @@ def __init__(self, client: OnebusawaySDK) -> None:
         self.arrival_and_departure = resources.ArrivalAndDepartureResourceWithRawResponse(client.arrival_and_departure)
         self.trip = resources.TripResourceWithRawResponse(client.trip)
         self.trips_for_location = resources.TripsForLocationResourceWithRawResponse(client.trips_for_location)
+        self.trip_details = resources.TripDetailsResourceWithRawResponse(client.trip_details)
 
 
 class AsyncOnebusawaySDKWithRawResponse:
@@ -465,6 +468,7 @@ def __init__(self, client: AsyncOnebusawaySDK) -> None:
         )
         self.trip = resources.AsyncTripResourceWithRawResponse(client.trip)
         self.trips_for_location = resources.AsyncTripsForLocationResourceWithRawResponse(client.trips_for_location)
+        self.trip_details = resources.AsyncTripDetailsResourceWithRawResponse(client.trip_details)
 
 
 class OnebusawaySDKWithStreamedResponse:
@@ -483,6 +487,7 @@ def __init__(self, client: OnebusawaySDK) -> None:
         )
         self.trip = resources.TripResourceWithStreamingResponse(client.trip)
         self.trips_for_location = resources.TripsForLocationResourceWithStreamingResponse(client.trips_for_location)
+        self.trip_details = resources.TripDetailsResourceWithStreamingResponse(client.trip_details)
 
 
 class AsyncOnebusawaySDKWithStreamedResponse:
@@ -505,6 +510,7 @@ def __init__(self, client: AsyncOnebusawaySDK) -> None:
         self.trips_for_location = resources.AsyncTripsForLocationResourceWithStreamingResponse(
             client.trips_for_location
         )
+        self.trip_details = resources.AsyncTripDetailsResourceWithStreamingResponse(client.trip_details)
 
 
 Client = OnebusawaySDK

src/onebusaway/_models.py

@@ -643,6 +643,14 @@ def validate_type(*, type_: type[_T], value: object) -> _T:
     return cast(_T, _validate_non_model_type(type_=type_, value=value))
 
 
+def set_pydantic_config(typ: Any, config: pydantic.ConfigDict) -> None:
+    """Add a pydantic config for the given type.
+
+    Note: this is a no-op on Pydantic v1.
+    """
+    setattr(typ, "__pydantic_config__", config)  # noqa: B010
+
+
 # our use of subclasssing here causes weirdness for type checkers,
 # so we just pretend that we don't subclass
 if TYPE_CHECKING:

src/onebusaway/resources/__init__.py

@@ -40,6 +40,14 @@
     CurrentTimeResourceWithStreamingResponse,
     AsyncCurrentTimeResourceWithStreamingResponse,
 )
+from .trip_details import (
+    TripDetailsResource,
+    AsyncTripDetailsResource,
+    TripDetailsResourceWithRawResponse,
+    AsyncTripDetailsResourceWithRawResponse,
+    TripDetailsResourceWithStreamingResponse,
+    AsyncTripDetailsResourceWithStreamingResponse,
+)
 from .stops_for_route import (
     StopsForRouteResource,
     AsyncStopsForRouteResource,
@@ -142,4 +150,10 @@
     "AsyncTripsForLocationResourceWithRawResponse",
     "TripsForLocationResourceWithStreamingResponse",
     "AsyncTripsForLocationResourceWithStreamingResponse",
+    "TripDetailsResource",
+    "AsyncTripDetailsResource",
+    "TripDetailsResourceWithRawResponse",
+    "AsyncTripDetailsResourceWithRawResponse",
+    "TripDetailsResourceWithStreamingResponse",
+    "AsyncTripDetailsResourceWithStreamingResponse",
 ]

src/onebusaway/resources/agencies_with_coverage.py

@@ -13,9 +13,7 @@
     async_to_raw_response_wrapper,
     async_to_streamed_response_wrapper,
 )
-from .._base_client import (
-    make_request_options,
-)
+from .._base_client import make_request_options
 from ..types.agencies_with_coverage_retrieve_response import AgenciesWithCoverageRetrieveResponse
 
 __all__ = ["AgenciesWithCoverageResource", "AsyncAgenciesWithCoverageResource"]

src/onebusaway/resources/agency.py

@@ -13,9 +13,7 @@
     async_to_raw_response_wrapper,
     async_to_streamed_response_wrapper,
 )
-from .._base_client import (
-    make_request_options,
-)
+from .._base_client import make_request_options
 from ..types.agency_retrieve_response import AgencyRetrieveResponse
 
 __all__ = ["AgencyResource", "AsyncAgencyResource"]
@@ -56,7 +54,7 @@ def retrieve(
         if not agency_id:
             raise ValueError(f"Expected a non-empty value for `agency_id` but received {agency_id!r}")
         return self._get(
-            f"/api/where/agency/{agency_id}.json",
+            f"/api/where/agency/agencyID.json",
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),
@@ -99,7 +97,7 @@ async def retrieve(
         if not agency_id:
             raise ValueError(f"Expected a non-empty value for `agency_id` but received {agency_id!r}")
         return await self._get(
-            f"/api/where/agency/{agency_id}.json",
+            f"/api/where/agency/agencyID.json",
             options=make_request_options(
                 extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
             ),