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)
3132from ...lib .polling_async import async_poll_until
3233from ...types .devbox_execution_detail_view import DevboxExecutionDetailView
33- from ...types .devboxes .execution_update_chunk import ExecutionUpdateChunk
3434from ...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 ,
0 commit comments