feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 102
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/runloop-ai%2Frunloop-d709c5c5b17fec3a155d3367a00e123712be9fabdc802d7f2069b77b79883057.yml
-openapi_spec_hash: 7a92b2d1612b211cc7507bdc49adf657
-config_hash: 3b21dd730a91da5e18dd16ab3e1870a8
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/runloop-ai%2Frunloop-aa2f6b7bd5f38374ef743af2f5399fc37358408730dcbb1305e181bb91a2e903.yml
+openapi_spec_hash: a3f793428f6b5de9a59ba8c80ee8bbea
+config_hash: a74944d06979c9df5e08aee874ae5caa

api.md

@@ -257,11 +257,7 @@ Methods:
 Types:
 
 ```python
-from runloop_api_client.types.devboxes import (
-    ExecutionUpdateChunk,
-    ExecutionStreamStderrUpdatesResponse,
-    ExecutionStreamStdoutUpdatesResponse,
-)
+from runloop_api_client.types.devboxes import ExecutionUpdateChunk
 ```
 
 Methods:
@@ -270,8 +266,8 @@ Methods:
 - <code title="post /v1/devboxes/{id}/execute_async">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">execute_async</a>(id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_execute_async_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devbox_async_execution_detail_view.py">DevboxAsyncExecutionDetailView</a></code>
 - <code title="post /v1/devboxes/{id}/execute_sync">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">execute_sync</a>(id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_execute_sync_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devbox_execution_detail_view.py">DevboxExecutionDetailView</a></code>
 - <code title="post /v1/devboxes/{devbox_id}/executions/{execution_id}/kill">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">kill</a>(execution_id, \*, devbox_id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_kill_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devbox_async_execution_detail_view.py">DevboxAsyncExecutionDetailView</a></code>
-- <code title="get /v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">stream_stderr_updates</a>(execution_id, \*, devbox_id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_stream_stderr_updates_params.py">params</a>) -> str</code>
-- <code title="get /v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stdout_updates">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">stream_stdout_updates</a>(execution_id, \*, devbox_id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_stream_stdout_updates_params.py">params</a>) -> str</code>
+- <code title="get /v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">stream_stderr_updates</a>(execution_id, \*, devbox_id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_stream_stderr_updates_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devboxes/execution_update_chunk.py">ExecutionUpdateChunk</a></code>
+- <code title="get /v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stdout_updates">client.devboxes.executions.<a href="./src/runloop_api_client/resources/devboxes/executions.py">stream_stdout_updates</a>(execution_id, \*, devbox_id, \*\*<a href="src/runloop_api_client/types/devboxes/execution_stream_stdout_updates_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devboxes/execution_update_chunk.py">ExecutionUpdateChunk</a></code>
 
 # Scenarios
 

src/runloop_api_client/resources/devboxes/executions.py

@@ -31,9 +31,8 @@
 )
 from ...lib.polling_async import async_poll_until
 from ...types.devbox_execution_detail_view import DevboxExecutionDetailView
+from ...types.devboxes.execution_update_chunk import ExecutionUpdateChunk
 from ...types.devbox_async_execution_detail_view import DevboxAsyncExecutionDetailView
-from ...types.devboxes.execution_stream_stderr_updates_response import ExecutionStreamStderrUpdatesResponse
-from ...types.devboxes.execution_stream_stdout_updates_response import ExecutionStreamStdoutUpdatesResponse
 
 __all__ = ["ExecutionsResource", "AsyncExecutionsResource"]
 
@@ -340,7 +339,7 @@ def stream_stderr_updates(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> Stream[ExecutionStreamStderrUpdatesResponse]:
+    ) -> Stream[ExecutionUpdateChunk]:
         """
         Tails the stderr logs for the given execution with SSE streaming
 
@@ -359,7 +358,6 @@ def stream_stderr_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        extra_headers = {"Accept": "text/plain", **(extra_headers or {})}
         return self._get(
             f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
             options=make_request_options(
@@ -371,9 +369,9 @@ def stream_stderr_updates(
                     {"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
                 ),
             ),
-            cast_to=str,
+            cast_to=ExecutionUpdateChunk,
             stream=True,
-            stream_cls=Stream[ExecutionStreamStderrUpdatesResponse],
+            stream_cls=Stream[ExecutionUpdateChunk],
         )
 
     def stream_stdout_updates(
@@ -388,7 +386,7 @@ def stream_stdout_updates(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> Stream[ExecutionStreamStdoutUpdatesResponse]:
+    ) -> Stream[ExecutionUpdateChunk]:
         """
         Tails the stdout logs for the given execution with SSE streaming
 
@@ -407,7 +405,6 @@ def stream_stdout_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        extra_headers = {"Accept": "text/plain", **(extra_headers or {})}
         return self._get(
             f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stdout_updates",
             options=make_request_options(
@@ -419,9 +416,9 @@ def stream_stdout_updates(
                     {"offset": offset}, execution_stream_stdout_updates_params.ExecutionStreamStdoutUpdatesParams
                 ),
             ),
-            cast_to=str,
+            cast_to=ExecutionUpdateChunk,
             stream=True,
-            stream_cls=Stream[ExecutionStreamStdoutUpdatesResponse],
+            stream_cls=Stream[ExecutionUpdateChunk],
         )
 
 
@@ -717,7 +714,7 @@ async def stream_stderr_updates(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> AsyncStream[ExecutionStreamStderrUpdatesResponse]:
+    ) -> AsyncStream[ExecutionUpdateChunk]:
         """
         Tails the stderr logs for the given execution with SSE streaming
 
@@ -736,7 +733,6 @@ async def stream_stderr_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        extra_headers = {"Accept": "text/plain", **(extra_headers or {})}
         return await self._get(
             f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
             options=make_request_options(
@@ -748,9 +744,9 @@ async def stream_stderr_updates(
                     {"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
                 ),
             ),
-            cast_to=str,
+            cast_to=ExecutionUpdateChunk,
             stream=True,
-            stream_cls=AsyncStream[ExecutionStreamStderrUpdatesResponse],
+            stream_cls=AsyncStream[ExecutionUpdateChunk],
         )
 
     async def stream_stdout_updates(
@@ -765,7 +761,7 @@ async def stream_stdout_updates(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> AsyncStream[ExecutionStreamStdoutUpdatesResponse]:
+    ) -> AsyncStream[ExecutionUpdateChunk]:
         """
         Tails the stdout logs for the given execution with SSE streaming
 
@@ -784,7 +780,6 @@ async def stream_stdout_updates(
             raise ValueError(f"Expected a non-empty value for `devbox_id` but received {devbox_id!r}")
         if not execution_id:
             raise ValueError(f"Expected a non-empty value for `execution_id` but received {execution_id!r}")
-        extra_headers = {"Accept": "text/plain", **(extra_headers or {})}
         return await self._get(
             f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stdout_updates",
             options=make_request_options(
@@ -796,9 +791,9 @@ async def stream_stdout_updates(
                     {"offset": offset}, execution_stream_stdout_updates_params.ExecutionStreamStdoutUpdatesParams
                 ),
             ),
-            cast_to=str,
+            cast_to=ExecutionUpdateChunk,
             stream=True,
-            stream_cls=AsyncStream[ExecutionStreamStdoutUpdatesResponse],
+            stream_cls=AsyncStream[ExecutionUpdateChunk],
         )
 
 

src/runloop_api_client/types/devboxes/__init__.py

@@ -52,6 +52,7 @@
 from .watched_file_response import WatchedFileResponse as WatchedFileResponse
 from .code_description_param import CodeDescriptionParam as CodeDescriptionParam
 from .computer_create_params import ComputerCreateParams as ComputerCreateParams
+from .execution_update_chunk import ExecutionUpdateChunk as ExecutionUpdateChunk
 from .file_contents_response import FileContentsResponse as FileContentsResponse
 from .health_status_response import HealthStatusResponse as HealthStatusResponse
 from .lsp_diagnostics_params import LspDiagnosticsParams as LspDiagnosticsParams
@@ -95,12 +96,6 @@
 from .execution_stream_stdout_updates_params import (
     ExecutionStreamStdoutUpdatesParams as ExecutionStreamStdoutUpdatesParams,
 )
-from .execution_stream_stderr_updates_response import (
-    ExecutionStreamStderrUpdatesResponse as ExecutionStreamStderrUpdatesResponse,
-)
-from .execution_stream_stdout_updates_response import (
-    ExecutionStreamStdoutUpdatesResponse as ExecutionStreamStdoutUpdatesResponse,
-)
 from .lsp_get_code_actions_for_diagnostic_params import (
     LspGetCodeActionsForDiagnosticParams as LspGetCodeActionsForDiagnosticParams,
 )

src/runloop_api_client/types/devboxes/execution_stream_stderr_updates_response.py

@@ -0,0 +1,15 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Optional
+
+from ..._models import BaseModel
+
+__all__ = ["ExecutionUpdateChunk"]
+
+
+class ExecutionUpdateChunk(BaseModel):
+    output: str
+    """The latest log stream chunk."""
+
+    offset: Optional[int] = None
+    """The byte offset of this chunk of log stream."""