Skip to content

Commit f347794

Browse files
feat(api): api update
1 parent aa4a6d9 commit f347794

10 files changed

Lines changed: 205 additions & 116 deletions

.stats.yml

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
configured_endpoints: 101
2-
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/runloop-ai%2Frunloop-6b4c63a026f224ec02ccd715e063e07107b545bb859218afaac2b3df84cd227a.yml
3-
openapi_spec_hash: 76072cd766a9c45cff8890bb2bb8b1d5
4-
config_hash: a8ac5e38099129b07ae4decb0774719d
1+
configured_endpoints: 102
2+
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/runloop-ai%2Frunloop-d709c5c5b17fec3a155d3367a00e123712be9fabdc802d7f2069b77b79883057.yml
3+
openapi_spec_hash: 7a92b2d1612b211cc7507bdc49adf657
4+
config_hash: 3b21dd730a91da5e18dd16ab3e1870a8

api.md

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,11 @@ Methods:
257257
Types:
258258

259259
```python
260-
from runloop_api_client.types.devboxes import ExecutionUpdateChunk
260+
from runloop_api_client.types.devboxes import (
261+
ExecutionUpdateChunk,
262+
ExecutionStreamStderrUpdatesResponse,
263+
ExecutionStreamStdoutUpdatesResponse,
264+
)
261265
```
262266

263267
Methods:
@@ -266,7 +270,8 @@ Methods:
266270
- <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>
267271
- <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>
268272
- <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>
269-
- <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_updates_params.py">params</a>) -> <a href="./src/runloop_api_client/types/devbox_async_execution_detail_view.py">DevboxAsyncExecutionDetailView</a></code>
273+
- <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>
274+
- <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>
270275

271276
# Scenarios
272277

src/runloop_api_client/resources/devboxes/executions.py

Lines changed: 20 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,14 @@
2626
execution_retrieve_params,
2727
execution_execute_sync_params,
2828
execution_execute_async_params,
29-
execution_stream_updates_params,
29+
execution_stream_stderr_updates_params,
30+
execution_stream_stdout_updates_params,
3031
)
3132
from ...lib.polling_async import async_poll_until
3233
from ...types.devbox_execution_detail_view import DevboxExecutionDetailView
33-
from ...types.devboxes.execution_update_chunk import ExecutionUpdateChunk
3434
from ...types.devbox_async_execution_detail_view import DevboxAsyncExecutionDetailView
35+
from ...types.devboxes.execution_stream_stderr_updates_response import ExecutionStreamStderrUpdatesResponse
36+
from ...types.devboxes.execution_stream_stdout_updates_response import ExecutionStreamStdoutUpdatesResponse
3537

3638
__all__ = ["ExecutionsResource", "AsyncExecutionsResource"]
3739

@@ -338,7 +340,7 @@ def stream_stdout_updates(
338340
extra_query: Query | None = None,
339341
extra_body: Body | None = None,
340342
timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
341-
) -> Stream[ExecutionUpdateChunk]:
343+
) -> Stream[ExecutionStreamStdoutUpdatesResponse]:
342344
"""
343345
Tails the stdout logs for the given execution with SSE streaming
344346
@@ -366,7 +368,7 @@ def stream_stdout_updates(
366368
extra_body=extra_body,
367369
timeout=timeout,
368370
query=maybe_transform(
369-
{"offset": offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
371+
{"offset": offset}, execution_stream_stdout_updates_params.ExecutionStreamStdoutUpdatesParams
370372
),
371373
),
372374
cast_to=DevboxAsyncExecutionDetailView,
@@ -384,7 +386,7 @@ def create_stream(last_offset: str | None) -> Stream[ExecutionUpdateChunk]:
384386
extra_body=extra_body,
385387
timeout=timeout,
386388
query=maybe_transform(
387-
{"offset": new_offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
389+
{"offset": new_offset}, execution_stream_stdout_updates_params.ExecutionStreamStdoutUpdatesParams
388390
),
389391
),
390392
cast_to=DevboxAsyncExecutionDetailView,
@@ -445,7 +447,7 @@ def stream_stderr_updates(
445447
extra_body=extra_body,
446448
timeout=timeout,
447449
query=maybe_transform(
448-
{"offset": offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
450+
{"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
449451
),
450452
),
451453
cast_to=DevboxAsyncExecutionDetailView,
@@ -463,7 +465,7 @@ def create_stream(last_offset: str | None) -> Stream[ExecutionUpdateChunk]:
463465
extra_body=extra_body,
464466
timeout=timeout,
465467
query=maybe_transform(
466-
{"offset": new_offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
468+
{"offset": new_offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
467469
),
468470
),
469471
cast_to=DevboxAsyncExecutionDetailView,
@@ -765,7 +767,7 @@ async def kill(
765767
cast_to=DevboxAsyncExecutionDetailView,
766768
)
767769

768-
async def stream_updates(
770+
async def stream_stderr_updates(
769771
self,
770772
execution_id: str,
771773
*,
@@ -777,9 +779,9 @@ async def stream_updates(
777779
extra_query: Query | None = None,
778780
extra_body: Body | None = None,
779781
timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
780-
) -> AsyncStream[ExecutionUpdateChunk]:
782+
) -> AsyncStream[ExecutionStreamStderrUpdatesResponse]:
781783
"""
782-
Tails the logs for the given execution with SSE streaming
784+
Tails the stderr logs for the given execution with SSE streaming
783785
784786
Args:
785787
offset: The byte offset to start the stream from
@@ -799,14 +801,14 @@ async def stream_updates(
799801
# If caller requested a raw or streaming response wrapper, return the underlying stream as-is
800802
if extra_headers and extra_headers.get(RAW_RESPONSE_HEADER):
801803
return await self._get(
802-
f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_updates",
804+
f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
803805
options=make_request_options(
804806
extra_headers=extra_headers,
805807
extra_query=extra_query,
806808
extra_body=extra_body,
807809
timeout=timeout,
808810
query=await async_maybe_transform(
809-
{"offset": offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
811+
{"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
810812
),
811813
),
812814
cast_to=DevboxAsyncExecutionDetailView,
@@ -817,14 +819,14 @@ async def stream_updates(
817819
async def create_stream(last_offset: str | None) -> AsyncStream[ExecutionUpdateChunk]:
818820
new_offset = last_offset if last_offset is not None else (None if isinstance(offset, NotGiven) else offset)
819821
return await self._get(
820-
f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_updates",
822+
f"/v1/devboxes/{devbox_id}/executions/{execution_id}/stream_stderr_updates",
821823
options=make_request_options(
822824
extra_headers=extra_headers,
823825
extra_query=extra_query,
824826
extra_body=extra_body,
825827
timeout=timeout,
826828
query=await async_maybe_transform(
827-
{"offset": new_offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
829+
{"offset": new_offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
828830
),
829831
),
830832
cast_to=DevboxAsyncExecutionDetailView,
@@ -885,7 +887,7 @@ async def stream_stdout_updates(
885887
extra_body=extra_body,
886888
timeout=timeout,
887889
query=await async_maybe_transform(
888-
{"offset": offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
890+
{"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
889891
),
890892
),
891893
cast_to=DevboxAsyncExecutionDetailView,
@@ -903,7 +905,7 @@ async def create_stream(last_offset: str | None) -> AsyncStream[ExecutionUpdateC
903905
extra_body=extra_body,
904906
timeout=timeout,
905907
query=await async_maybe_transform(
906-
{"offset": new_offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
908+
{"offset": new_offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
907909
),
908910
),
909911
cast_to=DevboxAsyncExecutionDetailView,
@@ -964,7 +966,7 @@ async def stream_stderr_updates(
964966
extra_body=extra_body,
965967
timeout=timeout,
966968
query=await async_maybe_transform(
967-
{"offset": offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
969+
{"offset": offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
968970
),
969971
),
970972
cast_to=DevboxAsyncExecutionDetailView,
@@ -982,7 +984,7 @@ async def create_stream(last_offset: str | None) -> AsyncStream[ExecutionUpdateC
982984
extra_body=extra_body,
983985
timeout=timeout,
984986
query=await async_maybe_transform(
985-
{"offset": new_offset}, execution_stream_updates_params.ExecutionStreamUpdatesParams
987+
{"offset": new_offset}, execution_stream_stderr_updates_params.ExecutionStreamStderrUpdatesParams
986988
),
987989
),
988990
cast_to=DevboxAsyncExecutionDetailView,

src/runloop_api_client/types/devboxes/__init__.py

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,6 @@
5252
from .watched_file_response import WatchedFileResponse as WatchedFileResponse
5353
from .code_description_param import CodeDescriptionParam as CodeDescriptionParam
5454
from .computer_create_params import ComputerCreateParams as ComputerCreateParams
55-
from .execution_update_chunk import ExecutionUpdateChunk as ExecutionUpdateChunk
5655
from .file_contents_response import FileContentsResponse as FileContentsResponse
5756
from .health_status_response import HealthStatusResponse as HealthStatusResponse
5857
from .lsp_diagnostics_params import LspDiagnosticsParams as LspDiagnosticsParams
@@ -77,7 +76,6 @@
7776
from .code_action_application_result import CodeActionApplicationResult as CodeActionApplicationResult
7877
from .execution_execute_async_params import ExecutionExecuteAsyncParams as ExecutionExecuteAsyncParams
7978
from .lsp_set_watch_directory_params import LspSetWatchDirectoryParams as LspSetWatchDirectoryParams
80-
from .execution_stream_updates_params import ExecutionStreamUpdatesParams as ExecutionStreamUpdatesParams
8179
from .lsp_get_code_segment_info_params import LspGetCodeSegmentInfoParams as LspGetCodeSegmentInfoParams
8280
from .lsp_set_watch_directory_response import LspSetWatchDirectoryResponse as LspSetWatchDirectoryResponse
8381
from .computer_mouse_interaction_params import ComputerMouseInteractionParams as ComputerMouseInteractionParams
@@ -91,6 +89,18 @@
9189
from .computer_keyboard_interaction_response import (
9290
ComputerKeyboardInteractionResponse as ComputerKeyboardInteractionResponse,
9391
)
92+
from .execution_stream_stderr_updates_params import (
93+
ExecutionStreamStderrUpdatesParams as ExecutionStreamStderrUpdatesParams,
94+
)
95+
from .execution_stream_stdout_updates_params import (
96+
ExecutionStreamStdoutUpdatesParams as ExecutionStreamStdoutUpdatesParams,
97+
)
98+
from .execution_stream_stderr_updates_response import (
99+
ExecutionStreamStderrUpdatesResponse as ExecutionStreamStderrUpdatesResponse,
100+
)
101+
from .execution_stream_stdout_updates_response import (
102+
ExecutionStreamStdoutUpdatesResponse as ExecutionStreamStdoutUpdatesResponse,
103+
)
94104
from .lsp_get_code_actions_for_diagnostic_params import (
95105
LspGetCodeActionsForDiagnosticParams as LspGetCodeActionsForDiagnosticParams,
96106
)

src/runloop_api_client/types/devboxes/execution_stream_updates_params.py renamed to src/runloop_api_client/types/devboxes/execution_stream_stderr_updates_params.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,10 @@
44

55
from typing_extensions import Required, TypedDict
66

7-
__all__ = ["ExecutionStreamUpdatesParams"]
7+
__all__ = ["ExecutionStreamStderrUpdatesParams"]
88

99

10-
class ExecutionStreamUpdatesParams(TypedDict, total=False):
10+
class ExecutionStreamStderrUpdatesParams(TypedDict, total=False):
1111
devbox_id: Required[str]
1212

1313
offset: str
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
2+
3+
from typing_extensions import TypeAlias
4+
5+
__all__ = ["ExecutionStreamStderrUpdatesResponse"]
6+
7+
ExecutionStreamStderrUpdatesResponse: TypeAlias = str
Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
2+
3+
from __future__ import annotations
4+
5+
from typing_extensions import Required, TypedDict
6+
7+
__all__ = ["ExecutionStreamStdoutUpdatesParams"]
8+
9+
10+
class ExecutionStreamStdoutUpdatesParams(TypedDict, total=False):
11+
devbox_id: Required[str]
12+
13+
offset: str
14+
"""The byte offset to start the stream from"""
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
2+
3+
from typing_extensions import TypeAlias
4+
5+
__all__ = ["ExecutionStreamStdoutUpdatesResponse"]
6+
7+
ExecutionStreamStdoutUpdatesResponse: TypeAlias = str

src/runloop_api_client/types/devboxes/execution_update_chunk.py

Lines changed: 0 additions & 40 deletions
This file was deleted.

0 commit comments

Comments
 (0)