~tjotdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZddlZddlmZddlmZddlmZdd lmZmZmZmZmZdd lmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*m+Z+m,Z,dd l-m.Z.m/Z/ddl0m1Z1ddl2m3Z3e rddl4m5Z5ddZ6ddZ7e e e8e8fZ9GddZ:dS)zFAsync SandboxClient class for interacting with the sandbox server API.) annotationsN)CallableMapping) TYPE_CHECKINGAnyOptionalUnion)utils)AsyncLangsmith) AsyncSandbox) SandboxClient_make_docker_context_tar_make_dockerfile_build_command_quote_path_segment_resolve_dockerfile_context)ResourceCreationErrorResourceNameConflictErrorResourceNotFoundErrorResourceTimeoutErrorSandboxAPIError)handle_client_http_errorhandle_sandbox_creation_error merge_headersvalidate_service_params validate_ttl)AsyncServiceURLResourceStatusSnapshot)SandboxMountConfig"validate_mount_config_proxy_config)SandboxProxyConfig)AsyncRetryTransport)AsyncRegistriesResourcereturnstrc^tjdd}|ddS)zGet the default sandbox API endpoint from environment. Derives the endpoint from LANGSMITH_ENDPOINT (or LANGCHAIN_ENDPOINT). ENDPOINTzhttps://api.smith.langchain.com)default/ /v2/sandboxes)ls_utils get_env_varrstrip)bases ]/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langsmith/sandbox/_async_client.py_get_default_api_endpointr08s5   4U V V VDkk# - - -- Optional[str]c*tjdS)z)Get the default API key from environment.API_KEY)r+r,r1r/_get_default_api_keyr6As   * **r1ceZdZdZdddddddsdZdtdZedudZdvdZdvdZ dwdZ dxdZ dxdZ dydZ dzd%Zdtd&Z d{ddd'ddddddddd( d|d7Z d{ddd'd8ddddddddd9 d}d<Zdd=d~d>Zdd=dd@ZdddddAddCZdd=ddDZdd=ddFZdGddHddLZdMdNddOddQZdMddRddSZdd=ddTZddUddVddZZd[ddddddUdd\dddZdddUddeddgZdd=ddhZdddddiddnZdd=ddoZ dpdqddOddrZ!dS)AsyncSandboxClientaAsync client for interacting with the Sandbox Server API. This client provides an async interface for managing sandboxes and snapshots. Example: # Uses LANGSMITH_ENDPOINT and LANGSMITH_API_KEY from environment async with AsyncSandboxClient() as client: # Create a sandbox with the default runtime and run commands async with await client.sandbox() as sandbox: result = await sandbox.run("python --version") print(result.stdout) Ng$@ api_endpointtimeoutapi_key max_retriesheadersr;r2r<floatr=r>intr?Optional[Mapping[str, str]]c|p td|_|p t}||_||_||_|rt|ni|_i}|r||d<|jrt||j}t|}tj ||||_ d|_dS)aInitialize the AsyncSandboxClient. Args: api_endpoint: Full URL of the sandbox API endpoint. If not provided, derived from LANGSMITH_ENDPOINT environment variable. timeout: Default HTTP timeout in seconds. api_key: API key for authentication. If not provided, uses LANGSMITH_API_KEY environment variable. max_retries: Maximum number of retries for transient errors (502, 503, 504), rate limits (429), and connection failures. Set to 0 to disable retries. Default: 3. headers: Optional default headers attached to every request on this client, including the data-plane ``/execute`` HTTP endpoint and the ``/execute/ws`` WebSocket upgrade. Use this to pass additional auth headers (e.g. ``X-Service-Key``). r)z X-Api-Key)r>) transportr<r?N)r0r- _base_urlr6_api_key_timeout _max_retriesdict_default_headersrr"httpx AsyncClient_http_registries_client) selfr;r<r=r>r?resolved_api_keyclient_headersrDs r/__init__zAsyncSandboxClient.__init__Ws2'E*C*E*EMMcRR"<&:&<&<(  'AH0PW b)+  ;*:N; '   R*>4;PQQN'K@@@ &.    =Ar1r$r%cd}|j|r|jdt| S|jS)z>Return the API root URL, without the ``/v2/sandboxes`` suffix.r*N)rEendswithlen)rOsuffixs r/ _api_rootzAsyncSandboxClient._api_roots@  > " "6 * * 2>.S[[L.1 1~r1r#c|j5t|j||jpd|_|jjjS)aManage sandbox image registries: create, list, retrieve, update, delete. A registry stores credentials for pulling private images. Create one, then pass its ``id`` as ``registry_id`` when building a snapshot. Example: registry = await client.registries.create( name="internal", url="registry.example.com", username="robot", password=os.environ["REGISTRY_PASSWORD"], ) snapshot = await client.create_snapshot( "internal-python", docker_image="registry.example.com/internal/python:3.12", fs_capacity_bytes=2 * 1024**3, registry_id=registry.id, ) N)r=base_urldefault_headers)rNr rFrWrJ sandboxes registriesrOs r/r\zAsyncSandboxClient.registriessR*  " *&4 )) $ 5 ='''D # &0;;r1RequestHeadersOptional[dict[str, str]]c>|dSt|jj|S)z8Merge default client headers with per-request overrides.N)rrMr?rOr?s r/_request_headersz#AsyncSandboxClient._request_headerss! ?4TZ/999r1cB|js|dSt|j|S)zMerge constructor-supplied default headers with per-request overrides. Used by the WebSocket exec path so headers like ``X-Service-Key`` set on the client are attached to the WS upgrade request. N)rJrras r/_ws_default_headersz&AsyncSandboxClient._ws_default_headerss+ $ 4T2G<<>++8((7777788#DD       DD s/ A4AA!! A/+A4.A//A44 BBc K|S)zEnter async context manager.r5r]s r/ __aenter__zAsyncSandboxClient.__aenter__s  r1exc_typeOptional[type]exc_valOptional[BaseException]exc_tb Optional[Any]c>K|d{VdS)zExit async context manager.N)ri)rOrvrxrzs r/ __aexit__zAsyncSandboxClient.__aexit__s.kkmmr1cd|jdS)zReturn a string representation of the instance. Returns: The string representation of the instance. zAsyncSandboxClient (API URL: ))rEr]s r/__repr__zAsyncSandboxClient.__repr__s At~@@@@r1 snapshot_namenamer<idle_ttl_secondsdelete_after_stop_secondsvcpus mem_bytesfs_capacity_bytes mount_config proxy_configr? snapshot_idrrr Optional[int]rrrrrOptional[SandboxMountConfig]rOptional[SandboxProxyConfig]r c fK|||||||||| | | |  d{V} d| _| S)aV Create a sandbox and return an AsyncSandbox instance. This is the primary method for creating sandboxes. Use it as an async context manager for automatic cleanup: async with await client.sandbox(snapshot_id="") as sandbox: result = await sandbox.run("echo hello") # Resolve by snapshot name instead of ID: async with await client.sandbox(snapshot_name="my-snap") as sandbox: result = await sandbox.run("echo hello") The sandbox is automatically deleted when exiting the context manager. For sandboxes with manual lifecycle management, use create_sandbox(). Args: snapshot_id: Optional snapshot ID to boot from. Mutually exclusive with ``snapshot_name``. snapshot_name: Snapshot name to boot from. Resolved server-side to a snapshot owned by the caller's tenant. Mutually exclusive with ``snapshot_id``. name: Optional sandbox name (auto-generated if not provided). timeout: Timeout in seconds when waiting for ready. idle_ttl_seconds: Idle timeout in seconds. The launcher automatically stops the sandbox after this duration of inactivity. Must be a multiple of 60. ``0`` explicitly disables the idle stop. When omitted (``None``), the server applies a default of ``600`` seconds (10 minutes). delete_after_stop_seconds: Seconds after the sandbox enters the ``stopped`` state before it (and its filesystem clone) are permanently deleted. Must be a multiple of 60. ``0`` disables stop-anchored deletion (manual cleanup required). When omitted (``None``), the server applies its configured default. vcpus: Number of vCPUs. mem_bytes: Memory in bytes. fs_capacity_bytes: Root filesystem capacity in bytes. mount_config: Mount configuration forwarded to the server as ``mount_config``. The backend expands mount auth into runtime proxy rules. Explicit AWS/GCP proxy rules in ``proxy_config`` conflict with mount auth for the same provider. proxy_config: Per-sandbox proxy configuration forwarded to the server as-is. Shape matches the backend `proxy_config` field: ``{"rules": [...], "no_proxy": [...], "access_control": {"allow_list": [...]}}`` or ``{"access_control": {"deny_list": [...]}}``. Use ``access_control.allow_list`` to restrict outbound HTTPS to a set of host patterns (exact domains, globs like ``*.example.com``, IPs, CIDRs, or ``~regex``). Use ``proxy_config`` with provider rule helpers such as ``aws_auth`` to let the proxy sign supported AWS HTTPS requests on the sandbox's behalf. Returns: AsyncSandbox instance. Raises: ResourceTimeoutError: If timeout waiting for sandbox to be ready. ResourceCreationError: If sandbox creation fails. SandboxClientError: For other errors. ValueError: If TTL values are invalid, or if both ``snapshot_id`` and ``snapshot_name`` are provided. rNT)create_sandbox _auto_delete)rOrrrr<rrrrrrrr?sbs r/sandboxzAsyncSandboxClient.sandboxssZ&& '-&?/%%'          r1T) rrr<wait_for_readyrrrrrrrr?rboolc K|r|rtdt|dt|d|jd}d|i}|r||d<|r||d<|r||d<|r||d <|||d<|||d<|||d <| | |d <| | |d <| t| | | |d<| | |d<|r|dznd} |j||||| d {V}|tj | |dS#tj $r}t|d }~wwxYw)a Create a new Sandbox. The sandbox is NOT automatically deleted. Use delete_sandbox() for cleanup, or use sandbox() for automatic cleanup with a context manager. Args: snapshot_id: Optional snapshot ID to boot from. Mutually exclusive with ``snapshot_name``. snapshot_name: Snapshot name to boot from. Resolved server-side to a snapshot owned by the caller's tenant. Mutually exclusive with ``snapshot_id``. name: Optional sandbox name (auto-generated if not provided). timeout: Timeout in seconds when waiting for ready (only used when wait_for_ready=True). wait_for_ready: If True (default), block until sandbox is ready. If False, return immediately with status "provisioning". Use get_sandbox_status() or wait_for_sandbox() to poll for readiness. idle_ttl_seconds: Idle timeout in seconds. The launcher automatically stops the sandbox after this duration of inactivity. Must be a multiple of 60. ``0`` explicitly disables the idle stop. When omitted (``None``), the server applies a default of ``600`` seconds (10 minutes). delete_after_stop_seconds: Seconds after the sandbox enters the ``stopped`` state before it (and its filesystem clone) are permanently deleted. Must be a multiple of 60. ``0`` disables stop-anchored deletion (manual cleanup required). When omitted (``None``), the server applies its configured default. vcpus: Number of vCPUs. mem_bytes: Memory in bytes. fs_capacity_bytes: Root filesystem capacity in bytes. mount_config: Mount configuration forwarded to the server as ``mount_config``. The backend expands mount auth into runtime proxy rules. Explicit AWS/GCP proxy rules in ``proxy_config`` conflict with mount auth for the same provider. proxy_config: Per-sandbox proxy configuration forwarded to the server as-is. Shape matches the backend `proxy_config` field: ``{"rules": [...], "no_proxy": [...], "access_control": {"allow_list": [...]}}`` or ``{"access_control": {"deny_list": [...]}}``. Use ``access_control.allow_list`` to restrict outbound HTTPS to a set of host patterns (exact domains, globs like ``*.example.com``, IPs, CIDRs, or ``~regex``). Use ``proxy_config`` with provider rule helpers such as ``aws_auth`` to let the proxy sign supported AWS HTTPS requests on the sandbox's behalf. Returns: Created AsyncSandbox. When wait_for_ready=False, the sandbox will have status="provisioning" and cannot be used for operations until ready. Raises: ResourceTimeoutError: If timeout waiting for sandbox to be ready. ResourceCreationError: If sandbox creation fails. SandboxClientError: For other errors. ValueError: If TTL values are invalid, or if both ``snapshot_id`` and ``snapshot_name`` are provided. z6At most one of snapshot_id or snapshot_name may be setrr/boxesrrrr<rNrrrrrr)jsonr<r?Fclient auto_delete) ValueErrorrrEr rMpostrbraise_for_statusr from_dictrrKHTTPStatusErrorr)rOrrrr<rrrrrrrrr?urlpayload http_timeoutresponsees r/rz!AsyncSandboxClient.create_sandboxVsR  W= WUVV V%'9:::.0KLLL''' n#   1%0GM "  5'4GO $  )!(GI   #"GFO  '*:G& ' $ 03LG/ 0  $GG   #,GK  (+>Er?cK|jdt|} |j|||d{V}|t j||dS#tj $r;}|j j dkrtd|dd |t|d}~wwxYw) aKGet a Sandbox by name. The sandbox is NOT automatically deleted. Use delete_sandbox() for cleanup. Args: name: Sandbox name. Returns: AsyncSandbox. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. /boxes/rNFr Sandbox ' ' not foundr resource_type)rErrMgetrbrr rrrKrr status_coderrrOrr?rrrs r/ get_sandboxzAsyncSandboxClient.get_sandboxs"CC(;D(A(ACC !Z^^C9N9Nw9W9W^XXXXXXXXH  % % ' ' ') % $   z%,,+1111 %Q ' ' '   sA1BC6CClist[AsyncSandbox]cKjd} j||d{V}||}fd|dgDS#t j$r9}|jj dkrtd|d|t|d}~wwxYw) zRList all Sandboxes. Returns: List of AsyncSandboxes. rrNc>g|]}tj|dS)Fr)r r).0crOs r/ z5AsyncSandboxClient.list_sandboxes..s;&q5IIIr1r[rAPI endpoint not found: %. Check that api_endpoint is correct. rErMrrbrrrKrrrrr)rOr?rrdatars` r/list_sandboxesz!AsyncSandboxClient.list_sandboxess!''' !Z^^C9N9Nw9W9W^XXXXXXXXH  % % ' ' '==??D+r22 $   z%,,%;s;;; %Q ' ' '  sA>BC4CC)new_namerrr?rctKt|dt|d|jdt|}i}|||d<|||d<|||d< |j||||d{V}|tj| |dS#tj $ra} | j j d krtd |d d | | j j dkrtd|dd | t!| d} ~ wwxYw)abUpdate a sandbox's properties. Args: name: Current sandbox name. new_name: New display name. idle_ttl_seconds: Idle timeout in seconds. Must be a multiple of 60. ``0`` disables idle-stop. ``None`` leaves the existing value unchanged. delete_after_stop_seconds: Seconds after entering ``stopped`` before deletion. Must be a multiple of 60. ``0`` disables stop-anchored deletion. ``None`` leaves the existing value unchanged. Returns: Updated AsyncSandbox. Raises: ResourceNotFoundError: If sandbox not found. ResourceNameConflictError: If new_name is already in use. SandboxClientError: For other errors. ValueError: If TTL values are invalid. rrrNrrr?FrrrrrrizSandbox name 'z' already in use)rrErrMpatchrbrr rrrKrrrrrr) rOrrrrr?rrrrs r/update_sandboxz!AsyncSandboxClient.update_sandboxs> %'9:::.0KLLLCC(;D(A(ACC"$  &GFO  '*:G& ' $ 03LG/ 0 !Z--'4+@+@+I+I.H  % % ' ' ') % $   z%,,+1111z%,,/?X???"+ %Q ' ' '  sA2CD7AD22D7ctK|jdt|} |j|||d{V}|dS#t j$r@}|jj dkrtd|dd|t|Yd}~dSd}~wwxYw) zDelete a Sandbox. Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rrNrrrrr rErrMdeleterbrrKrrrrrrs r/delete_sandboxz!AsyncSandboxClient.delete_sandboxNsCC(;D(A(ACC (!Z..T227;;/H  % % ' ' ' ' '$ ( ( (z%,,+1111 %Q ' ' ' ' ' ' ' ' '  (A A((B775B22B7rcK|jdt|d} |j|||d{V}|t j|S#tj $r;}|j j dkrtd|dd |t|d}~wwxYw) aGet the provisioning status of a sandbox. This is a lightweight endpoint designed for high-frequency polling during sandbox provisioning. It returns only the status fields without full sandbox data. Args: name: Sandbox name. Returns: ResourceStatus with status and status_message. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rz/statusrNrrrrr)rErrMrrbrrrrrKrrrrrrs r/get_sandbox_statusz%AsyncSandboxClient.get_sandbox_statushs&JJ(;D(A(AJJJ !Z^^C9N9Nw9W9W^XXXXXXXXH  % % ' ' '!+HMMOO<< <$   z%,,+1111 %Q ' ' '   sA.B C6CCiXexpires_in_secondsr?portrrcKtjdtd}d}dfd } j||d{V}|tj| | S#tj $r;} | j j d krtd d d | t| d} ~ wwxYw)aGet an authenticated URL for a service running inside a sandbox. Returns an :class:`AsyncServiceURL` whose async accessors auto-refresh the token transparently before it expires. The object also provides async HTTP helper methods (``.get``, ``.post``, etc.) that inject the authentication header automatically. Args: name: Sandbox name. 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. rz /service-url)rrr$rcFKd{VS)Nr)service)rr?rrrOsr/ _refresherz.AsyncSandboxClient.service.._refreshersL#5 & r1rN)rrrrrr)r$r)rrErrMrrbrrrrrKrrrrr) rOrrrr?rrrrrs ````` r/rzAsyncSandboxClient.servicesr< &8999OO(;D(A(AOOO7IJJ           !Z__'4+@+@+I+I-H  % % ' ' '",X]]__TTT T$   z%,,+1111 %Q ' ' '   sA1B44C>6C99C>xg?)r< poll_intervalr?rcKddl}||z} |||d{V}|jdkr|||d{VS|jdkrt |jpdd ||z }|dkrtd |d |d d|j tj t||d{V)aPoll until a sandbox reaches "ready" or "failed" status. Uses the lightweight status endpoint for polling, then fetches the full sandbox data once ready. Args: name: Sandbox name. timeout: Maximum time to wait in seconds. poll_interval: Time between status checks in seconds. Returns: AsyncSandbox in "ready" status. Raises: ResourceCreationError: If sandbox status becomes "failed". ResourceTimeoutError: If timeout expires while still "provisioning". ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rNTrreadyfailedzSandbox provisioning failedrrr' not ready after sr last_status) time monotonicrstatusrrstatus_messagerrmsleepmin) rOrr<rr?rdeadliner remainings r/wait_for_sandboxz#AsyncSandboxClient.wait_for_sandboxsF6  >>##g- ?2242IIIIIIIIF}''!--dG-DDDDDDDDD}((+)J-J"+!4>>#3#33IA~~*BBBBBB"+ &  -M9 = =>> > > > > > > >! ?r1r<r?cK|jdt|d} |j|i||d{V}|nQ#t j$r?}|jj dkrtd|dd |t|Yd}~nd}~wwxYw| ||| d{VS) aStart a stopped sandbox and wait until ready. Args: name: Sandbox name. timeout: Timeout in seconds when waiting for ready. Returns: AsyncSandbox in "ready" status. 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. rz/startrNrrrrrr) rErrMrrbrrKrrrrrr)rOrr<r?rrrs r/ start_sandboxz AsyncSandboxClient.start_sandboxs<,II(;D(A(AIII (!Z__"d&;&;G&D&D-H  % % ' ' ' '$ ( ( (z%,,+1111 %Q ' ' ' ' ' ' ' '  (**4'*RRRRRRRRRsA A))B785B22B7cxK|jdt|d} |j|i||d{V}|dS#t j$r@}|jj dkrtd|dd |t|Yd}~dSd}~wwxYw) zStop a running sandbox (preserves sandbox files for later restart). Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rz/stoprNrrrrr) rErrMrrbrrKrrrrrrs r/ stop_sandboxzAsyncSandboxClient.stop_sandboxsHH(;D(A(AHHH (!Z__"d&;&;G&D&D-H  % % ' ' ' ' '$ ( ( (z%,,+1111 %Q ' ' ' ' ' ' ' ' '  (sA A**B995B44B9<) registry_idr<r? docker_imagerrcK|jd}|||d}|||d< |j||||d{V} | t j| } n'#tj $r} t| d} ~ wwxYw| | j ||d{VS)aBuild a snapshot from a Docker image. Blocks until the snapshot is ready (polls with 2s interval). Args: name: Snapshot name. docker_image: Docker image to build from (e.g., "python:3.12-slim"). fs_capacity_bytes: Filesystem capacity in bytes. registry_id: Private registry ID. timeout: Timeout in seconds when waiting for ready. Returns: Snapshot in "ready" status. Raises: ResourceTimeoutError: If snapshot doesn't become ready within timeout. ResourceCreationError: If snapshot build fails. SandboxClientError: For other errors. /snapshots)rrrNrrr) rErMrrbrrrrrKrrwait_for_snapshotid) rOrrrrr<r?rrrsnapshotrs r/create_snapshotz"AsyncSandboxClient.create_snapshot3s::+++(!2# #   "%0GM " !Z__'4+@+@+I+I-H  % % ' ' ')(--//::HH$    $Q ' ' '  ++ K',         sA0B B0B++B0.)context build_argstarget on_build_logrrr<r? dockerfileUnion[str, os.PathLike[str]]rrrrOptional[Callable[[str], Any]]c Kt||\} } dtjjdd}dtjjdd}t j|d}t j|d}dtjj}t j|d}t j|d }||| || || d{V4d{V }||tj t| d{V| | d{V| d |zd z|zdz|zdz|z| | d{V| t|| |||||| ||| d{V}|j dkrtdd||j|||| | d{Vcdddd{VS#1d{VswxYwYdS)aiBuild a snapshot from a local Dockerfile context. ``vcpus`` and ``mem_bytes`` size the temporary builder sandbox. The build runs BuildKit plus the native snapshotter's layer copies inside it, which contend for a single core by default, so giving the builder an extra vCPU can cut a cold build's wall time substantially. zsnapshot-builder-N z/var/lib/langsmith-build/rz context.tarzlangsmith-snapshot-build:z buildkit-rootz buildkit-run)rr<rrrr?rzrm -rf z && mkdir -p z && tar -xf z -C )remote_contextdockerfile_rel image_ref buildkit_root buildkit_runrr)r< on_stdout on_stderrr?rz Dockerfile snapshot build failedrrrrr<r?)ruuiduuid4hex posixpathjoinrwriterm to_threadrrunr exit_codercapture_snapshotr)rOrrrrrrrrrr<r? context_pathr builder_name build_rootr remote_tarrrrrresults r/create_snapshot_from_dockerfilez2AsyncSandboxClient.create_snapshot_from_dockerfilehs,(C:w'W'W$ nB4:<<+;CRC+@BB I1A#2#1FHH " I>>^J >> B 0@BB !z?CC  ~j.AA / &        6 6 6 6 6 6 6 6 --'(@,OOOOOOOO          ++ !!"!!! !    !!          #;;.#1#1'"/!-)! &&'F1$$+6",.. &"3 /_6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 s3C&G,, G69G6r sandbox_namec"K|jdt|d}d|i}|||d<|||d< |j||||d{V} | t j| } nM#tj $r;} | j j dkrtd |d d | t| d} ~ wwxYw|| j|| d{VS)aoCapture a snapshot from a running sandbox. Blocks until the snapshot is ready (polls with 2s interval). Args: sandbox_name: Name of the sandbox to capture from. name: Snapshot name. timeout: Timeout in seconds when waiting for ready. 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. rz /snapshotrNrrrrrrrrr)rErrMrrbrrrrrKrrrrrrr) rOrrrrr<r?rrrrrs r/r z#AsyncSandboxClient.capture_snapshots8TT(;L(I(ITTT#)4.  #&2GN #  (+= 0``. Useful for paginating through large result sets in combination with ``limit``. Returns: A single page of Snapshots matching the provided filters. rNrrr)paramsr?c6g|]}tj|Sr5)rr)rrs r/rz5AsyncSandboxClient.list_snapshots..Hs#MMMaH&q))MMMr1 snapshotsrrrr) rOrrrr?rrrrrs r/list_snapshotsz!AsyncSandboxClient.list_snapshotssY<+++!#  $&3F? #  #F7O  %F8  !Z^^~--g66,H  % % ' ' '==??DMM488K3L3LMMM M$   z%,,%;s;;; %Q ' ' '  sA?B%%C-44C((C-ctK|jdt|} |j|||d{V}|dS#t j$r@}|jj dkrtd|dd|t|Yd}~dSd}~wwxYw) zDelete a snapshot. Args: snapshot_id: Snapshot UUID. Raises: ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. rrNrrrrrrrs r/delete_snapshotz"AsyncSandboxClient.delete_snapshotRsNN,? ,L,LNN (!Z..T227;;/H  % % ' ' ' ' '$ ( ( (z%,,+9999 %Q ' ' ' ' ' ' ' ' '  (ri,g@cKddl}||z} |||d{V}|jdkr|S|jdkrt |jpdd ||z }|dkrt d |d |d d|j tjt||d{V)a&Poll until a snapshot reaches "ready" or "failed" status. Args: snapshot_id: Snapshot UUID. timeout: Maximum time to wait in seconds. poll_interval: Time between status checks in seconds. Returns: Snapshot in "ready" status. Raises: ResourceCreationError: If snapshot status becomes "failed". ResourceTimeoutError: If timeout expires. ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. rNTrrrzSnapshot build failedrrrrrr) rrrrrrrrmrr) rOrr<rr?rrrrs r/rz$AsyncSandboxClient.wait_for_snapshotls 0  >>##g- ?!..{G.LLLLLLLLH'))(**++F/F",!4>>#3#33IA~~*JJJJJJ", ( -M9 = =>> > > > > > > >! ?r1) r;r2r<r@r=r2r>rAr?rBr$r%)r$r#)r?r^r$r_)r$r )r$rg)r$r8)rvrwrxryrzr{r$rg)N)rr2rr2rr2r<rArrrrrrrrrrrrrrr?r^r$r )rr2rr2rr2r<rArrrrrrrrrrrrrrrrr?r^r$r )rr%r?r^r$r )r?r^r$r) rr%rr2rrrrr?r^r$r )rr%r?r^r$rg)rr%r?r^r$r) rr%rrArrAr?r^r$r) rr%r<rArr@r?r^r$r )rr%r<rAr?r^r$r )rr%rr%rrArr2r<rAr?r^r$r)rr%rrrrArrrrBrr2rrrrrrr<rAr?r^r$r)rr%rr%rr2rrr<rAr?r^r$r)rr%r?r^r$r) rr2rrrrr?r^r$r)rr%r?r^r$rg) rr%r<rArr@r?r^r$r)"__name__ __module__ __qualname____doc__rRrWpropertyr\rbrdrfrirsrur}rrrrrrrrrrrrrrr rr"r$rr5r1r/r8r8Isi   '+!%/3(A(A(A(A(A(AT<<<X<8:::: ====    $2222 $AAAA&*\(,"*.37##'+/5959"&\\\\\\@&*z(,"#*.37##'+/5959"&zzzzzzz7;D,0>#'*.37"&>>>>>>B7;((((((67;L#&"& 666666x""& .?.?.?.?.?.?h"& $S$S$S$S$S$SLJN((((((D&*"&3 3 3 3 3 3 v1426 $7;##'"&[[[[[[D'++/"&4 4 4 4 4 4 n>B@(,# $"& 888888v>B((((((<""& +?+?+?+?+?+?+?+?r1r8r&)r$r2);r* __future__rrmosrrcollections.abcrrtypingrrrr rK langsmithr r+langsmith._openapi_clientr langsmith.sandbox._async_sandboxr langsmith.sandbox._clientr rrrrlangsmith.sandbox._exceptionsrrrrrlangsmith.sandbox._helpersrrrrrlangsmith.sandbox._modelsrrrlangsmith.sandbox._mountsrr langsmith.sandbox._proxy_configr!langsmith.sandbox._transportr"8langsmith._openapi_client.resources.sandboxes.registriesr#r0r6r%r^r8r5r1r/r;sLL""""""  --------666666666666 ''''''444444999999 ?>>>>><<<<<< ....++++ '#s(+,N?N?N?N?N?N?N?N?N?N?r1