feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 91
+configured_endpoints: 92
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/runloop-ai%2Frunloop-1d4b018cbfb409baf83725737f00789a9ddbbdbdbe12db1ac7a1fd2cf9c453f0.yml
 openapi_spec_hash: 1c533f386f6d3d3802d353cc6f1df547
-config_hash: 55cf3b0829d3d91846df7c4cfab7db0d
+config_hash: 33b544375e4a932cbb2890f79a9aa040

api.md

@@ -297,6 +297,7 @@ Methods:
 - <code title="get /v1/scenarios/runs">client.scenarios.runs.<a href="./src/runloop_api_client/resources/scenarios/runs.py">list</a>(\*\*<a href="src/runloop_api_client/types/scenarios/run_list_params.py">params</a>) -> <a href="./src/runloop_api_client/types/scenario_run_view.py">SyncBenchmarkRunsCursorIDPage[ScenarioRunView]</a></code>
 - <code title="post /v1/scenarios/runs/{id}/cancel">client.scenarios.runs.<a href="./src/runloop_api_client/resources/scenarios/runs.py">cancel</a>(id) -> <a href="./src/runloop_api_client/types/scenario_run_view.py">ScenarioRunView</a></code>
 - <code title="post /v1/scenarios/runs/{id}/complete">client.scenarios.runs.<a href="./src/runloop_api_client/resources/scenarios/runs.py">complete</a>(id) -> <a href="./src/runloop_api_client/types/scenario_run_view.py">ScenarioRunView</a></code>
+- <code title="post /v1/scenarios/runs/{id}/download_logs">client.scenarios.runs.<a href="./src/runloop_api_client/resources/scenarios/runs.py">download_logs</a>(id) -> BinaryAPIResponse</code>
 - <code title="post /v1/scenarios/runs/{id}/score">client.scenarios.runs.<a href="./src/runloop_api_client/resources/scenarios/runs.py">score</a>(id) -> <a href="./src/runloop_api_client/types/scenario_run_view.py">ScenarioRunView</a></code>
 
 ## Scorers

src/runloop_api_client/resources/scenarios/runs.py

@@ -9,10 +9,18 @@
 from ..._compat import cached_property
 from ..._resource import SyncAPIResource, AsyncAPIResource
 from ..._response import (
+    BinaryAPIResponse,
+    AsyncBinaryAPIResponse,
+    StreamedBinaryAPIResponse,
+    AsyncStreamedBinaryAPIResponse,
     to_raw_response_wrapper,
     to_streamed_response_wrapper,
     async_to_raw_response_wrapper,
+    to_custom_raw_response_wrapper,
     async_to_streamed_response_wrapper,
+    to_custom_streamed_response_wrapper,
+    async_to_custom_raw_response_wrapper,
+    async_to_custom_streamed_response_wrapper,
 )
 from ...pagination import SyncBenchmarkRunsCursorIDPage, AsyncBenchmarkRunsCursorIDPage
 from ..._base_client import AsyncPaginator, make_request_options
@@ -210,6 +218,48 @@ def complete(
             cast_to=ScenarioRunView,
         )
 
+    def download_logs(
+        self,
+        id: str,
+        *,
+        # 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,
+        idempotency_key: str | None = None,
+    ) -> BinaryAPIResponse:
+        """
+        Download a zip file containing all logs for a Scenario run from the associated
+        devbox.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+
+          idempotency_key: Specify a custom idempotency key for this request
+        """
+        if not id:
+            raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
+        extra_headers = {"Accept": "application/zip", **(extra_headers or {})}
+        return self._post(
+            f"/v1/scenarios/runs/{id}/download_logs",
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                idempotency_key=idempotency_key,
+            ),
+            cast_to=BinaryAPIResponse,
+        )
+
     def score(
         self,
         id: str,
@@ -439,6 +489,48 @@ async def complete(
             cast_to=ScenarioRunView,
         )
 
+    async def download_logs(
+        self,
+        id: str,
+        *,
+        # 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,
+        idempotency_key: str | None = None,
+    ) -> AsyncBinaryAPIResponse:
+        """
+        Download a zip file containing all logs for a Scenario run from the associated
+        devbox.
+
+        Args:
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+
+          idempotency_key: Specify a custom idempotency key for this request
+        """
+        if not id:
+            raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
+        extra_headers = {"Accept": "application/zip", **(extra_headers or {})}
+        return await self._post(
+            f"/v1/scenarios/runs/{id}/download_logs",
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                idempotency_key=idempotency_key,
+            ),
+            cast_to=AsyncBinaryAPIResponse,
+        )
+
     async def score(
         self,
         id: str,
@@ -496,6 +588,10 @@ def __init__(self, runs: RunsResource) -> None:
         self.complete = to_raw_response_wrapper(
             runs.complete,
         )
+        self.download_logs = to_custom_raw_response_wrapper(
+            runs.download_logs,
+            BinaryAPIResponse,
+        )
         self.score = to_raw_response_wrapper(
             runs.score,
         )
@@ -517,6 +613,10 @@ def __init__(self, runs: AsyncRunsResource) -> None:
         self.complete = async_to_raw_response_wrapper(
             runs.complete,
         )
+        self.download_logs = async_to_custom_raw_response_wrapper(
+            runs.download_logs,
+            AsyncBinaryAPIResponse,
+        )
         self.score = async_to_raw_response_wrapper(
             runs.score,
         )
@@ -538,6 +638,10 @@ def __init__(self, runs: RunsResource) -> None:
         self.complete = to_streamed_response_wrapper(
             runs.complete,
         )
+        self.download_logs = to_custom_streamed_response_wrapper(
+            runs.download_logs,
+            StreamedBinaryAPIResponse,
+        )
         self.score = to_streamed_response_wrapper(
             runs.score,
         )
@@ -559,6 +663,10 @@ def __init__(self, runs: AsyncRunsResource) -> None:
         self.complete = async_to_streamed_response_wrapper(
             runs.complete,
         )
+        self.download_logs = async_to_custom_streamed_response_wrapper(
+            runs.download_logs,
+            AsyncStreamedBinaryAPIResponse,
+        )
         self.score = async_to_streamed_response_wrapper(
             runs.score,
         )

tests/api_resources/scenarios/test_runs.py

@@ -5,11 +5,19 @@
 import os
 from typing import Any, cast
 
+import httpx
 import pytest
+from respx import MockRouter
 
 from tests.utils import assert_matches_type
 from runloop_api_client import Runloop, AsyncRunloop
 from runloop_api_client.types import ScenarioRunView
+from runloop_api_client._response import (
+    BinaryAPIResponse,
+    AsyncBinaryAPIResponse,
+    StreamedBinaryAPIResponse,
+    AsyncStreamedBinaryAPIResponse,
+)
 from runloop_api_client.pagination import SyncBenchmarkRunsCursorIDPage, AsyncBenchmarkRunsCursorIDPage
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
@@ -166,6 +174,62 @@ def test_path_params_complete(self, client: Runloop) -> None:
                 "",
             )
 
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    def test_method_download_logs(self, client: Runloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+        run = client.scenarios.runs.download_logs(
+            "id",
+        )
+        assert run.is_closed
+        assert run.json() == {"foo": "bar"}
+        assert cast(Any, run.is_closed) is True
+        assert isinstance(run, BinaryAPIResponse)
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    def test_raw_response_download_logs(self, client: Runloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+
+        run = client.scenarios.runs.with_raw_response.download_logs(
+            "id",
+        )
+
+        assert run.is_closed is True
+        assert run.http_request.headers.get("X-Stainless-Lang") == "python"
+        assert run.json() == {"foo": "bar"}
+        assert isinstance(run, BinaryAPIResponse)
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    def test_streaming_response_download_logs(self, client: Runloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+        with client.scenarios.runs.with_streaming_response.download_logs(
+            "id",
+        ) as run:
+            assert not run.is_closed
+            assert run.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            assert run.json() == {"foo": "bar"}
+            assert cast(Any, run.is_closed) is True
+            assert isinstance(run, StreamedBinaryAPIResponse)
+
+        assert cast(Any, run.is_closed) is True
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    def test_path_params_download_logs(self, client: Runloop) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"):
+            client.scenarios.runs.with_raw_response.download_logs(
+                "",
+            )
+
     @parametrize
     def test_method_score(self, client: Runloop) -> None:
         run = client.scenarios.runs.score(
@@ -358,6 +422,62 @@ async def test_path_params_complete(self, async_client: AsyncRunloop) -> None:
                 "",
             )
 
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    async def test_method_download_logs(self, async_client: AsyncRunloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+        run = await async_client.scenarios.runs.download_logs(
+            "id",
+        )
+        assert run.is_closed
+        assert await run.json() == {"foo": "bar"}
+        assert cast(Any, run.is_closed) is True
+        assert isinstance(run, AsyncBinaryAPIResponse)
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    async def test_raw_response_download_logs(self, async_client: AsyncRunloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+
+        run = await async_client.scenarios.runs.with_raw_response.download_logs(
+            "id",
+        )
+
+        assert run.is_closed is True
+        assert run.http_request.headers.get("X-Stainless-Lang") == "python"
+        assert await run.json() == {"foo": "bar"}
+        assert isinstance(run, AsyncBinaryAPIResponse)
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    async def test_streaming_response_download_logs(self, async_client: AsyncRunloop, respx_mock: MockRouter) -> None:
+        respx_mock.post("/v1/scenarios/runs/id/download_logs").mock(
+            return_value=httpx.Response(200, json={"foo": "bar"})
+        )
+        async with async_client.scenarios.runs.with_streaming_response.download_logs(
+            "id",
+        ) as run:
+            assert not run.is_closed
+            assert run.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            assert await run.json() == {"foo": "bar"}
+            assert cast(Any, run.is_closed) is True
+            assert isinstance(run, AsyncStreamedBinaryAPIResponse)
+
+        assert cast(Any, run.is_closed) is True
+
+    @parametrize
+    @pytest.mark.respx(base_url=base_url)
+    async def test_path_params_download_logs(self, async_client: AsyncRunloop) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"):
+            await async_client.scenarios.runs.with_raw_response.download_logs(
+                "",
+            )
+
     @parametrize
     async def test_method_score(self, async_client: AsyncRunloop) -> None:
         run = await async_client.scenarios.runs.score(