ޠjNz,SrSSKJr SSKJr SSKJrJr SSKJ r J r J r J r J r JrJr SSKJr SSKJrJrJr SSKJr SS KJrJrJrJrJrJrJr SS K J!r! SS K"J#r#J$r$J%r%J&r& \ (aSS K'J(r( SS K)J*r* SSK+J,r, \ \\-\-4r.\"SS55r/g)z?Sandbox class for interacting with a specific sandbox instance.) annotations)Mapping) dataclassfield) TYPE_CHECKINGAnyCallableLiteralOptionalUnionoverload)httpx)DataplaneNotConfiguredErrorResourceNotFoundErrorSandboxRetryableConnectionError)handle_sandbox_http_error) CommandHandleDownloadContentDisposition DownloadURLExecutionResult ServiceURLSnapshot_StreamEndedBeforeStarted)Tunnel)WEBSOCKETS_AVAILABLE _retry_delayconnect_deadlineopen_timeout_for)AsyncSandboxClient AsyncSandbox) SandboxClientc`\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)XSandbox*aRepresents an active sandbox for running commands and file operations. This class is typically obtained from SandboxClient.sandbox() and supports the 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: with client.sandbox(snapshot_id="") as sandbox: result = 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$)zCreate a Sandbox from API response dict. Args: data: API response dictionary containing sandbox data. client: Parent SandboxClient for operations. auto_delete: Whether to delete the sandbox on context exit. Returns: Sandbox instance. r'r)r*r,r+r-r.r/r1r2r3r4r5r6r7r:r<)get)clsdataclient auto_deletes T/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/sandbox/_sandbox.py from_dictSandbox.from_dicths2" &"% ((?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 an AsyncSandbox 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: AsyncSandboxClient to use for operations. If not provided, one is created with the same configuration as this sandbox's client (see :meth:`SandboxClient.to_async`). Returns: AsyncSandbox referring to the same sandbox. rr r'r)r*r,r-r.r/r1r2r3r4r5r6r7r:r<Fr?) langsmith.sandbox._async_sandboxr!r'r)r*r,r-r.r/r1r2r3r4r5r6r7r:to_async)selfrCr!s rErKSandbox.to_asyncs  B  ,, ww ;;   ..     "22 '+&D&D  (( ** nn #44 %0Fdll6K6K6M !  rHcU$)zEnter context manager.r?rLs rE __enter__Sandbox.__enter__s rHcUR(a'URRUR5 gg![a gf=f)z6Exit context manager, optionally deleting the sandbox.N)r<r:delete_sandboxr' Exception)rLexc_typeexc_valexc_tbs rE__exit__Sandbox.__exit__sA     ++DII6   s%: AAcnUR(d[SURS35eUR$)aReturn the dataplane URL. The client does not gate on lifecycle status: a stopped sandbox is resumed by the platform when the dataplane request arrives, so only the presence of a URL is required here. A genuinely not-ready box surfaces the server's ``SandboxNotReadyError`` from the request itself. Returns: The dataplane URL. Raises: DataplaneNotConfiguredError: If dataplane_url is not configured. z Sandbox 'zW' does not have a dataplane_url configured. Runtime operations require a dataplane URL.)r)rr'rOs rE_require_dataplane_urlSandbox._require_dataplane_urls=!!-DII;'>> !!!rH.) timeoutenvcwdshell on_stdout on_stderr idle_timeoutkill_on_disconnect ttl_secondsptyheaderswaitc gNr?rLcommandr]r^r_r`rarbrcrdrerfrgrhs rErun Sandbox.runs"rH) r]r^r_r`rarbrcrdrerfrgc grjr?rks rErmrns"rH<z /bin/bashi,iXc LU (dU(dU(a [S5eUR5 U (+=(d U=(d UnU(aURUUUUUU UUUU U U U S9 $[(aURUUUUUSSSUU U U U S9 $UR UUUUUU S9$)aExecute a command in the sandbox. 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 a CommandHandle immediately for streaming output, kill, stdin input, and reconnection. Cannot be combined with on_stdout/on_stderr callbacks. Returns: ExecutionResult when wait=True (default). CommandHandle 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`rhrarbrcrdrerfrgTN)r]r^r_r`rg) ValueErrorr[_run_wsr _run_http)rLrlr]r^r_r`rarbrcrdrerfrgrhuse_wss rErmrns@iR  ##%3Y3) <<##)#5'  $ <<)#5'  ~~    rH)rcrdrerfrgc SSKnSSKJn SSKJn UR 5nUR RnU"5RnUUUUUU U U U S. nUR RU 5nU(aUUS'Sn[5n[U5US'U"UUU40UD6unn[UUUUUS9nU(dU$UR.$![[4anUS - nU[R:ae[![R"S US - --[R$5n['U[5(a [)UU5nUb&UUR+5- nUS::ae[!UU5nUR-U5 SnAOSnAff=fGM) z"Execute via WebSocket /execute/ws.rN) run_ws_stream)uuid7) command_idr]r^r_r`rcrdrerfrg open_timeout)rarb)timelangsmith.sandbox._ws_executerwlangsmith.uuidrxr[r:_api_keyhex_ws_default_headersrrrrrMAX_AUTO_RECONNECTSmin _BACKOFF_BASE _BACKOFF_MAX isinstancer monotonicsleepresult)rLrlr]r^r_r`rhrarbrcrdrerfrgr}rwrxr)api_keyry ws_kwargsmergedattemptdeadline msg_streamcontrolhandleexcbackoff remainings rErsSandbox._run_wsss$ ?(335 ,,'' W[[ %("4& % 11': #)Ii #%(8(BIn %"/# # J  $&'' .M}}1*/ $ 1 ]>>>!//113EF!..c#BCC*38G' (4>>+; ;I A~!'95G 7##) $#s% CFB&FFcUR5nUS3nUUUS.n UbX9S'UbXIS'URRRUU US-URR U5S9n U R 5 U R 5n [U RSS 5U RS S 5U RS S 5S 9$![Ran [U 5 eSn A ff=f)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 rErtSandbox._run_https335 x(#  ? EN ? EN ||)).."  55g> /H  % % '==?D"xx"-xx"-((;3  $$  %a (  sBCC- C((C-r) stdout_offset stderr_offsetrgc SSKJn UR5nURRnUUS.nURR U5n U (aXS'U"UUU40UD6up[ U U UUUUS9$)aSReconnect 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: A CommandHandle 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)rrrg)ryrr)r~rr[r:rrr) rLryrrrgrr)rreconnect_kwargsrrrs rE reconnectSandbox.reconnects2 F335 ,,''+*, 11': *0Y '1          !''   rHr]rgc UR5nUS3n[U[5(aURS5nSSU40nURR R USU0UUURRU5S9nUR5 g![Ran [U 5 Sn A gSn A ff=f)aWrite content to a file in the sandbox. 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 rEwrite Sandbox.write/s,335 w' gs # #nnW-G&'*+ )||))..~ 55g> /H  % % '$$ ) %a ( ( )sABB?* B::B?cUR5nUS3nURRRUSU0UURR U5S9nUR 5 UR $![RaGnURRS:Xa[SUSURS3SS 9Ue[U5 eS nAff=f) aXRead a file from the sandbox. 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]rgizFile 'z' not found in sandbox ''r) resource_typeN)r[r:rr@rrrrrr status_coderr'r)rLrr]rgr)rrrs rEread Sandbox.readZs*335 y) ||))--~ 55g> .H  % % '## #$$ zz%%,+TF":499+QG"( &a (  sAA44CAC  C local_portmax_reconnectsrgc SUs=::aS::dO [SUS35eU(aSUs=::aS::dO [SUS35eUR5nURRn[ UUUUUUS9nUR 5 U$)aFOpen 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.). Use as a context manager for automatic cleanup:: with sandbox.tunnel(remote_port=5432) as t: conn = psycopg2.connect(host="127.0.0.1", port=t.local_port) Or manage the lifecycle explicitly:: t = sandbox.tunnel(remote_port=5432) # ... use tunnel ... t.close() 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: A Tunnel instance (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 r)rrr[r:rr_start)rL remote_portrrrgr)rts rEtunnelSandbox.tunnelsPK(5(? }AN  a:66>zl!L 335 ,,''    !)    rHexpires_in_secondsrgcNURRURUUUS9$)aQGet an authenticated URL for a service running in this sandbox. Returns a :class:`ServiceURL` whose properties 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: ServiceURL 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. r)r:servicer')rLportrrgs rErSandbox.services02||## II 1 $  rHr content_typecontent_dispositionrgc RURRURUUUUUS9$)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. r)r:generate_download_urlr')rLrrrrrgs rErSandbox.generate_download_urls7L||11 II 1% 3 2  rHxcURRURXS9nURUlURUlg)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 rEstart Sandbox.startsC*LL.. IIw/  && &44rHrgcZURRURUS9 SUlg)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. rstoppedN)r: stop_sandboxr'r,rLrgs rEstop Sandbox.stop,s( !!$))W!=  rHcLURRURUS9 g)zDelete this sandbox. Args: headers: Optional per-request header overrides. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rN)r:rSr'rs rEdeleteSandbox.delete;s ##DIIw#?rHcNURRURUUUS9$)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. r)r:capture_snapshotr')rLr'r]rgs rErSandbox.capture_snapshotGs0.||,, II  -  rH)r)r,)T)rBzdict[str, Any]rCr"rDr;returnr$)rCzOptional[AsyncSandboxClient]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, CommandHandle])rlr&r]rr^rr_r(r`r&rhr;rarrbrrcrrdr;rerrfr;rgrrr)rlr&r]rr^rr_r(r`r&rgrrr) ryr&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 rmrsrtrrrrrrrrrr__static_attributes__r?rHrEr$r$*sd&R I#'M='B FC$(NM( $J $ $J $&*m*/3}3 $J $!%K%E=#I}#'+}+#trsE"#(SSS2 A-B=7'#s(+, x  x   x  rH