ޠjt{<SrSSKJr SSKrSSKrSSKJr SSKJrJ r SSK J r J r J r JrJrJrJr SSKJr SSKJrJrJr SS KJr SS KJrJrJrJrJrJ r J!r! SS K"J#r# SS K$J%r%J&r&J'r'J(r( \ (aSS K)J*r* SSK+J,r, SSK-J.r. \\\/\/4r0\"SS55r1g)z0AsyncSandbox class for async sandbox operations.) annotationsN)Mapping) dataclassfield) TYPE_CHECKINGAnyCallableLiteralOptionalUnionoverload)httpx)DataplaneNotConfiguredErrorResourceNotFoundErrorSandboxRetryableConnectionError)handle_sandbox_http_error)AsyncCommandHandleAsyncServiceURLDownloadContentDisposition DownloadURLExecutionResultSnapshot_StreamEndedBeforeStarted) AsyncTunnel)WEBSOCKETS_AVAILABLE _retry_delayconnect_deadlineopen_timeout_for)AsyncSandboxClient) SandboxClientSandboxc`\rSrSr%SrS\S'SrS\S'SrS\S'S rS\S 'Sr S\S 'Sr S\S 'Sr S\S 'Sr S\S'Sr S\S'SrS\S'SrS\S'SrS\S'SrS\S'SrS\S'\"SSS9rS\S'\"SSS9rS\S'\SDSESjj5rSS.SFSjjrSGS jrSHS!jrSIS"jr\S#S#S#S#S#S#S#S#S#S#S#S#S$. SJS%jj5r\S#S#S#S#S#S#S#S#S#S#S#S&. SKS'jj5rS(SSS)SSS*SS+SSSS$. SLS,jjrS*SS+SSS-.SMS.jjrSNS/jrS0S0SS1.SOS2jjr S(SS3.SPS4jjr!S(SS3.SQS5jjr"S0S6SS7.SRS8jjr#S+SS9.SSS:jjr$SSSSS;.STS<jjr%S=SS3.SUS>jjr&SS?.SVS@jjr'SS?.SVSAjjr(S(SS3.SWSBjjr)SCr*g)X AsyncSandbox,a$Represents an active sandbox for running commands and file operations async. This class is typically obtained from AsyncSandboxClient.sandbox() and supports the async context manager protocol for automatic cleanup. Attributes: name: Display name (can be updated). dataplane_url: URL for data plane operations (file I/O, command execution). Only functional when status is "ready". id: Unique identifier (UUID). Remains constant even if name changes. May be None for resources created before ID support was added. status: Sandbox lifecycle status. One of "provisioning", "ready", "failed", "stopped". status_message: Human-readable details when status is "failed", None otherwise. created_at: Timestamp when the sandbox was created. updated_at: Timestamp when the sandbox was last updated. idle_ttl_seconds: Idle timeout TTL in seconds (``0`` means disabled). Newly-created sandboxes receive a server-side default of ``600`` seconds (10 minutes) when the caller did not set ``idle_ttl_seconds`` explicitly. The launcher stops the sandbox after this many idle seconds; deletion is anchored to ``stopped_at`` and controlled by ``delete_after_stop_seconds`` (see below). delete_after_stop_seconds: Seconds after a sandbox enters the ``stopped`` state before it (and its filesystem clone) are permanently deleted. ``0`` disables stop-anchored deletion; ``None`` falls back to the server default. stopped_at: Timestamp when the sandbox transitioned to ``stopped``, or ``None`` while running. The deletion deadline is ``stopped_at + delete_after_stop_seconds``. snapshot_id: Snapshot ID used to create this sandbox. vcpus: Number of vCPUs allocated. mem_bytes: Memory allocation in bytes. fs_capacity_bytes: Root filesystem capacity in bytes. Example: async with await client.sandbox( snapshot_id="" ) as sandbox: result = await sandbox.run("python --version") print(result.stdout) strnameN Optional[str] dataplane_urlidreadystatusstatus_message created_at updated_at Optional[int]idle_ttl_secondsdelete_after_stop_seconds stopped_at snapshot_idvcpus mem_bytesfs_capacity_bytesF)reprdefaultr_clientTbool _auto_deletec U"S0SURSS5_SURS5_SURS5_SURSS5_SURS5_SURS5_S URS 5_S URS 5_S URS 5_S URS 5_S URS 5_SURS5_SURS5_SURS5_SU_SU_6$)a Create an AsyncSandbox from API response dict. Args: data: API response dictionary containing sandbox data. client: Parent AsyncSandboxClient for operations. auto_delete: Whether to delete the sandbox on context exit. Returns: AsyncSandbox instance. r'r)r*r,r+r-r.r/r1r2r3r4r5r6r7r:r<)get)clsdataclient auto_deletes Z/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/sandbox/_async_sandbox.py from_dictAsyncSandbox.from_dictls2" &"% ((?3 xx~ 88Hg.   88$45  xx -  xx - "XX&89 '+hh/J&K xx - / ((7# hh{+ #hh':;  %!  )rCcSSKJn U"S0SUR_SUR_SUR_SUR _SUR _SUR_S UR_S UR_S UR_S UR_S UR_SUR_SUR_SUR_SUbUOUR R#5_SS_6$)aCreate a Sandbox for the same underlying sandbox. The returned instance has ``auto_delete`` disabled so the sandbox's lifecycle stays tied to this instance; both refer to the same server-side sandbox. Args: client: SandboxClient to use for operations. If not provided, one is created with the same configuration as this sandbox's client (see :meth:`AsyncSandboxClient.to_sync`). Returns: Sandbox referring to the same sandbox. rr!r'r)r*r,r-r.r/r1r2r3r4r5r6r7r:r<Fr?)langsmith.sandbox._sandboxr"r'r)r*r,r-r.r/r1r2r3r4r5r6r7r:to_sync)selfrCr"s rErKAsyncSandbox.to_syncs  7  ,, ww ;;   ..     "22 '+&D&D  (( ** nn #44 %0Fdll6J6J6L !  rHc# U$7f)zEnter async context manager.r?rLs rE __aenter__AsyncSandbox.__aenter__s  sc# UR(a/URRUR5IShvN ggN![a gf=f7f)z> !!!rH.) timeoutenvcwdshell on_stdout on_stderr idle_timeoutkill_on_disconnect ttl_secondsptyheaderswaitc  # g7fNr?rLcommandr]r^r_r`rarbrcrdrerfrgrhs rErunAsyncSandbox.runs ") r]r^r_r`rarbrcrdrerfrgc  # g7frjr?rks rErmrns "!ro<z /bin/bashi,iXc # U (dU(dU(a [S5eUR5 U (+=(d U=(d UnU(a#URUUUUUU UUUU U U U S9 IShvN $[(a#URUUUUUSSSUU U U U S9 IShvN $UR UUUUUU S9IShvN $NNN"N7f)a Execute a command in the sandbox asynchronously. Args: command: Shell command to execute. timeout: Command timeout in seconds. env: Environment variables to set for the command. cwd: Working directory for command execution. If None, uses sandbox default. shell: Shell to use for command execution. Defaults to "/bin/bash". on_stdout: Callback invoked with each stdout chunk as it arrives. Blocks until the command completes and returns ExecutionResult. Cannot be combined with wait=False. on_stderr: Callback invoked with each stderr chunk as it arrives. Blocks until the command completes and returns ExecutionResult. Cannot be combined with wait=False. idle_timeout: Idle timeout in seconds. If the command has no connected clients for this duration, it is killed. Defaults to 300 (5 minutes). Set to -1 for no idle timeout. Only applies to WebSocket execution. kill_on_disconnect: If True, kill the command immediately when the last client disconnects. Defaults to False (command continues running and can be reconnected to). ttl_seconds: How long (in seconds) a finished command's session is kept for reconnection. Defaults to 600 (10 minutes). Set to -1 to keep indefinitely. pty: If True, allocate a pseudo-terminal for the command. Useful for commands that require a TTY (e.g., interactive programs, commands that use terminal control codes). Defaults to False. wait: If True (default), block until the command completes and return ExecutionResult. If False, return an AsyncCommandHandle immediately for streaming output, kill, stdin input, and reconnection. Cannot be combined with on_stdout/on_stderr callbacks. Returns: ExecutionResult when wait=True (default). AsyncCommandHandle when wait=False. Raises: ValueError: If wait=False is combined with callbacks. DataplaneNotConfiguredError: If dataplane_url is not configured. SandboxOperationError: If command execution fails. CommandTimeoutError: If command exceeds its timeout. SandboxConnectionError: If connection to sandbox fails after retries. SandboxNotReadyError: If sandbox is not ready. SandboxClientError: For other errors. z}Cannot combine wait=False with on_stdout/on_stderr callbacks. Use wait=False and iterate the CommandHandle, or use callbacks.) r]r^r_r`rhrarbrcrdrerfrgNT)r]r^r_r`rg) ValueErrorr[_run_wsr _run_http)rLrlr]r^r_r`rarbrcrdrerfrgrhuse_wss rErmrns@iR  ##%3Y3) ##)#5'& $ )#5'& ^^  $   E& s6A/C1C2-CC C;C<CCC)rcrdrerfrgc # SSKnSSKJn SSKJn UR 5nUR RnU"5RnUUUUUU U U U S. nUR RU 5nU(aUUS'Sn[5n[U5US'U"UUU40UD6IShvN unn[UUUUUS9nUR5IShvN U(dU$UR2IShvN $NKN$![[4anUS - nU[R :ae[#[R$S US - --[R&5n[)U[5(a [+UU5nUb+U[,R."5- nUS::ae[#UU5nUR0"U5IShvN SnAOSnAff=fGMAN7f) z"Execute via WebSocket /execute/ws.rN)run_ws_stream_async)uuid7) command_idr]r^r_r`rcrdrerfrg open_timeout)rarb)asynciolangsmith.sandbox._ws_executerxlangsmith.uuidryr[r:_api_keyhex_ws_default_headersrrr_ensure_startedrrMAX_AUTO_RECONNECTSmin _BACKOFF_BASE _BACKOFF_MAX isinstancertime monotonicsleepresult)rLrlr]r^r_r`rhrarbrcrdrerfrgr~rxryr)api_keyrz ws_kwargsmergedattemptdeadline msg_streamcontrolhandleexcbackoff remainings rErtAsyncSandbox._run_wsvs$ E(335 ,,'' W[[ %("4& % 11': #)Ii #%(8(BIn %(;) )# J (## F -,,....M]]""S#/*/ - 1 /CCC&44gk8JK&33c#BCC*38G' (4>>+; ;I A~!'95GmmG,,,) -%V#sgB$G &C2'G <C6C4C6G -G .G 4C66GB/G5F86G;G GG c# UR5nUS3nUUUS.n UbX9S'UbXIS'URRRUU US-URR U5S9IShvN n U R 5 U R 5n [U RSS 5U RS S 5U RS S 5S 9$N_![Ran [U 5 eSn A ff=f7f)z9Execute via HTTP POST /execute (existing implementation).z/execute)rlr]r`Nr^r_ )jsonr]rgstdoutr>stderr exit_code)rrr) r[r:_httppost_request_headersraise_for_statusrrr@rHTTPStatusErrorr) rLrlr]r^r_r`rgr)urlpayloadresponserBes rEruAsyncSandbox._run_https 335 x(#  ? EN ? EN !\\//44"  55g> 5H  % % '==?D"xx"-xx"-((;3 $$  %a (  s<*C<AC2C3ACC<CC9( C44C99C<r) stdout_offset stderr_offsetrgc # SSKJn UR5nURRnUUS.nURR U5n U (aXS'U"UUU40UD6IShvN up[ U U UUUUS9$N7f)aYReconnect to a running or recently-finished command. Resumes output from the given byte offsets. Any output produced while the client was disconnected is replayed from the server's ring buffer. Args: command_id: The command ID from handle.command_id. stdout_offset: Byte offset to resume stdout from (default: 0). stderr_offset: Byte offset to resume stderr from (default: 0). Returns: An AsyncCommandHandle for the command. Raises: SandboxOperationError: If command_id is not found or session expired. SandboxConnectionError: If connection to sandbox fails after retries. r)reconnect_ws_stream_async)rrrgN)rzrr)rrr[r:rrr) rLrzrrrgrr)rreconnect_kwargsrrrs rE reconnectAsyncSandbox.reconnects2 L335 ,,''+*, 11': *0Y '$=   %  %   "   !''    sA&A?(A=)A?r]rgc # UR5nUS3n[U[5(aURS5nSSU40nURR R USU0UUURRU5S9IShvN nUR5 gN![Ran [U 5 Sn A gSn A ff=f7f)aWrite content to a file in the sandbox asynchronously. Args: path: Target file path in the sandbox. content: File content (str or bytes). timeout: Request timeout in seconds. Raises: DataplaneNotConfiguredError: If dataplane_url is not configured. SandboxOperationError: If file write fails. SandboxConnectionError: If connection to sandbox fails after retries. SandboxNotReadyError: If sandbox is not ready. SandboxClientError: For other errors. z/uploadzutf-8filepath)paramsfilesr]rgN) r[rr&encoder:rrrrrrr) rLrcontentr]rgr)rrrrs rEwriteAsyncSandbox.write3s,335 w' gs # #nnW-G&'*+ )!\\//44~ 55g> 5H  % % '$$ ) %a ( ( )sCACAB" B  B"C B""C 6 CCC  Cc# UR5nUS3nURRRUSU0UURR U5S9IShvN nUR 5 UR $N ![RaGnURRS:Xa[SUSURS3S S 9Ue[U5 eSnAff=f7f) agRead a file from the sandbox asynchronously. Args: path: File path to read. Supports both absolute paths (e.g., /tmp/file.txt) and relative paths (resolved from /home/user/). timeout: Request timeout in seconds. Returns: File contents as bytes. Raises: DataplaneNotConfiguredError: If dataplane_url is not configured. ResourceNotFoundError: If the file doesn't exist. SandboxOperationError: If file read fails. SandboxConnectionError: If connection to sandbox fails after retries. SandboxNotReadyError: If sandbox is not ready. SandboxClientError: For other errors. z /downloadr)rr]rgNizFile 'z' not found in sandbox ''r) resource_type)r[r:rr@rrrrrr status_coderr'r)rLrr]rgr)rrrs rEreadAsyncSandbox.read^s*335 y) !\\//33~ 55g> 4H  % % '## #$$ zz%%,+TF":499+QG"( &a (  s<CABA>B=C>BCACCC local_portmax_reconnectsrgc # SUs=::aS::dO [SUS35eU(aSUs=::aS::dO [SUS35eUR5nURRn[ UUUUUUS9n[ R "5nURSURR5IShvN U$N7f)aOpen a TCP tunnel to a port inside the sandbox. Creates a local TCP listener that forwards connections through a yamux-multiplexed WebSocket to the specified port inside the sandbox. Works with any TCP protocol (databases, Redis, HTTP, etc.). Usage:: async with await sandbox.tunnel(remote_port=5432) as t: conn = await asyncpg.connect(host="127.0.0.1", port=t.local_port) Args: remote_port: TCP port inside the sandbox to tunnel to (1-65535). local_port: Local port to listen on. Defaults to mirroring remote_port. Use 0 to let the OS pick an available port. max_reconnects: Maximum number of automatic reconnect attempts when the WebSocket session drops. Set to 0 to disable. Returns: An AsyncTunnel instance (async context manager). Raises: ValueError: If port values are out of range. DataplaneNotConfiguredError: If dataplane_url is not configured. SandboxNotReadyError: If sandbox is not ready. r|iz-remote_port must be between 1 and 65535 (got )z,local_port must be between 1 and 65535 (got rN) rsr[r:rrr~get_running_looprun_in_executor_tunnel_start) rL remote_portrrrgr)rtloops rEtunnelAsyncSandbox.tunnelsDK(5(? }AN  a:66>zl!L 335 ,,''    !)  '')""4)9)9::: ;sB6C8B?9Cexpires_in_secondsrgcj# URRURUUUS9IShvN $N7f)aaGet an authenticated URL for a service running in this sandbox. Returns an :class:`AsyncServiceURL` whose async accessors auto-refresh the token transparently before it expires. Args: port: Port the service is listening on inside the sandbox. expires_in_seconds: Token TTL in seconds (1--86400, default 600). headers: Optional per-request header overrides. Returns: AsyncServiceURL with auto-refreshing token and HTTP helpers. Raises: ResourceNotFoundError: If sandbox not found. ValueError: If port or expires_in_seconds is out of range. SandboxClientError: For other errors. rN)r:servicer')rLportrrgs rErAsyncSandbox.services=2\\)) II 1 *    *313r content_typecontent_dispositionrgc n# URRURUUUUUS9IShvN $N7f)aCreate a link that downloads one file from this sandbox. The link carries its own token, so anyone holding the URL can fetch that one file without a LangSmith credential. Fetching wakes a stopped sandbox. Do not modify the file after minting a link for it. The link is pinned to a path, not to a snapshot of the contents, so a later write to that path may or may not be reflected in what the link serves. Write a new file and mint a new link when the contents change. Args: path: File path inside the sandbox. expires_in_seconds: Link TTL in seconds. Omit for a link that never expires. content_type: Content-Type to serve the file as. content_disposition: Content-Disposition to serve the file with, either ``"attachment"`` or ``"inline"``. headers: Optional per-request header overrides. Returns: DownloadURL with the link and its expiry, if any. Raises: ResourceNotFoundError: If sandbox not found. ValueError: If expires_in_seconds is not positive. SandboxClientError: For other errors. rN)r:generate_download_urlr')rLrrrrrgs rEr"AsyncSandbox.generate_download_urlsDL\\77 II 1% 3 8    s ,535xc# URRURXS9IShvN nURUlURUlgN'7f)aStart a stopped sandbox and wait until ready. After starting, the sandbox's status and dataplane_url are updated in place. Args: timeout: Timeout in seconds when waiting for ready. headers: Optional per-request header overrides. Raises: ResourceNotFoundError: If sandbox not found. ResourceCreationError: If sandbox fails during startup. ResourceTimeoutError: If sandbox doesn't become ready within timeout. SandboxClientError: For other errors. rN)r: start_sandboxr'r,r))rLr]rg refresheds rEstartAsyncSandbox.startsP*,,44 IIw5   && &44  s(AA(Argcv# URRURUS9IShvN SUlgN 7f)zStop a running sandbox (preserves sandbox files for later restart). Args: headers: Optional per-request header overrides. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rNstopped)r: stop_sandboxr'r,rLrgs rEstopAsyncSandbox.stop+s7ll'' 7'CCC   Ds (97 9ch# URRURUS9IShvN gN7f)zDelete this sandbox. Args: headers: Optional per-request header overrides. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rN)r:rSr'rs rEdeleteAsyncSandbox.delete:s(ll))$))W)EEEs (202cj# URRURUUUS9IShvN $N7f)aCapture a snapshot from this sandbox. Args: name: Snapshot name. timeout: Timeout in seconds when waiting for ready. headers: Optional per-request header overrides. Returns: Snapshot in "ready" status. Raises: ResourceNotFoundError: If sandbox not found. ResourceTimeoutError: If snapshot doesn't become ready within timeout. ResourceCreationError: If snapshot capture fails. SandboxClientError: For other errors. rN)r:capture_snapshotr')rLr'r]rgs rErAsyncSandbox.capture_snapshotFs=.\\22 II  3    r)r)r,)T)rBzdict[str, Any]rCrrDr;returnr$)rCzOptional[SandboxClient]rr")rr$)rUzOptional[type]rVzOptional[BaseException]rWz Optional[Any]rNone)rr&)rlr&r]intr^Optional[dict[str, str]]r_r(r`r&raOptional[Callable[[str], Any]]rbrrcrrdr;rerrfr;rgRequestHeadersrhz Literal[True]rr)rlr&r]rr^rr_r(r`r&rarrbrrcrrdr;rerrfr;rgrrhzLiteral[False]rr)rlr&r]rr^rr_r(r`r&rarrbrrcrrdr;rerrfr;rgrrhr;r*Union[ExecutionResult, AsyncCommandHandle])rlr&r]rr^rr_r(r`r&rhr;rarrbrrcrrdr;rerrfr;rgrrr)rlr&r]rr^rr_r(r`r&rgrrr) rzr&rrrrrgrrr) rr&rzUnion[str, bytes]r]rrgrrr)rr&r]rrgrrbytes) rrrrrrrgrrr)rrrrrgrrr) rr&rr0rr(rz$Optional[DownloadContentDisposition]rgrrr)r]rrgrrr)rgrrr)r'r&r]rrgrrr)+__name__ __module__ __qualname____firstlineno____doc____annotations__r)r*r,r-r.r/r1r2r3r4r5r6r7rr:r< classmethodrFrKrPrXr[r rmrtrurrrrrrrrrr__static_attributes__r?rHrEr$r$,sd(V I#'M='B FC$(NM( $J $ $J $&*m*/3}3 $J $!%K%E=#I}#'+}+#(UD"AG AE48L$8 ! ! ! #!  !  ! ! F<@" H   )    "* (+ 4747#&"%!  &   22!  !$ (+ 4747#&"%!! ! & !  !!2!2!!!!!! !! !!!,(,! 4848#("&s s  s & s  s s 2s 2s s !s s s  s s 4!s @ #("&\#\# \# & \#  \#\#\#2\#2\#\#!\#\#\# \# 4!\#|'' ' & '  '' ' 'Z"& 4 4  4  4  4  4 v"& ))))#))  ))  )) ))X,.))%()8F) )^"& 66 6  6  6 6x#&"&         H-1&*DH"&- - * - $ - B -  -  - d"& 55 5  567;  9= F "&          rHr$)2r __future__rr~rcollections.abcr dataclassesrrtypingrrr r r r r langsmith._openapi_client._httpxrlangsmith.sandbox._exceptionsrrrlangsmith.sandbox._helpersrlangsmith.sandbox._modelsrrrrrrrlangsmith.sandbox._tunnelrrrrrrlangsmith.sandbox._async_clientrlangsmith.sandbox._clientr rJr"r&rr$r?rHrEr s6" #(SSS2 A2B72'#s(+, u  u   u  rH