jܽldZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZddlZddlmZddlmZddlmZdd lmZmZmZmZmZmZdd lmZm Z m!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-m.Z.m/Z/dd l0m1Z1m2Z2ddl3m4Z4ddl5m6Z6e rddl7m8Z8ddZ9ddZ:e e e;e;fZ<GddZ=y)zFAsync SandboxClient class for interacting with the sandbox server API.) annotationsN)CallableMapping) TYPE_CHECKINGAnyOptionalUnion)utils)AsyncLangsmith) AsyncSandbox) SandboxClient_box_url_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)AsyncServiceURLDownloadContentDisposition DownloadURLResourceStatusSnapshot)SandboxMountConfig"validate_mount_config_proxy_config)SandboxProxyConfig)AsyncRetryTransport)AsyncRegistriesResourcecXtjdd}|jddS)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 i/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/sandbox/_async_client.py_get_default_api_endpointr1;s.    4U VDkk# } --c,tjdS)z)Get the default API key from environment.API_KEY)r,r-r2r0_get_default_api_keyr6Ds    **r2ceZdZdZdddddd d9dZd:dZed;dZdd Z d>d Z d?dZ d@dZd:dZ dAdddddddddddd dBdZ dAddddddddddddd dCdZdd dDdZdd dEdZddddd dFdZdd dGdZdd dHdZddd dId Zddddd! dJd"Zd#d$dd% dKd&Zd#dd' dLd(ZdddGd)Zdd*dd+ dMd,Z dAd-dddddd*dd. dNd/Zddd*dd0 dOd1Zdd dPd2Zddddd3 dQd4Z dd dRd5Z!d6d7dd% dSd8Z"y)TAsyncSandboxClientaAsync 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_retriesheaderscl|xs tjd|_|xs t}||_||_||_|r t|ni|_i}|r||d<|jrt||j}t|}tj||||_ d|_y)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)r1r. _base_urlr6_api_key_timeout _max_retriesdict_default_headersrr%httpx AsyncClient_http_registries_client) selfr;r<r=r>r?resolved_api_keyclient_headersrAs r0__init__zAsyncSandboxClient.__init__Zs2'E*C*EMMcR"<&:&<(  'AHW b)+ *:N; '  *>4;P;PQN'K@ &&.  =Ar2cd}|jj|r|jdt| S|jS)z>Return the API root URL, without the ``/v2/sandboxes`` suffix.r+N)rBendswithlen)rLsuffixs r0 _api_rootzAsyncSandboxClient._api_roots:  >> " "6 *>>.S[L1 1~~r2c|j9t|j|j|jxsd|_|jj j S)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)rKr rCrTrG sandboxes registriesrLs r0rYzAsyncSandboxClient.registriessV*  " " *&4 ) $ 5 5 ='D # &&00;;;r2cH|yt|jj|S)z8Merge default client headers with per-request overrides.N)rrJr?rLr?s r0_request_headersz#AsyncSandboxClient._request_headerss! ?TZZ//99r2cL|js|yt|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)rGrr\s r0_ws_default_headersz&AsyncSandboxClient._ws_default_headerss' $$T22G<>+((7,( $   s/A.AA A+(A.*A++A.. A:9A:cK|Sw)zEnter async context manager.r5rZs r0 __aenter__zAsyncSandboxClient.__aenter__s  sc@K|jd{y7w)zExit async context manager.N)rc)rLexc_typeexc_valexc_tbs r0 __aexit__zAsyncSandboxClient.__aexit__skkms c"d|jdS)zReturn a string representation of the instance. Returns: The string representation of the instance. zAsyncSandboxClient (API URL: ))rBrZs r0__repr__zAsyncSandboxClient.__repr__s /t~~.>a@@r2 snapshot_namenamer<idle_ttl_secondsdelete_after_stop_secondsvcpus mem_bytesfs_capacity_bytes mount_config proxy_configr?c jK|j||||||||| | | |  d{} d| _| S7 w)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. ryNT)create_sandbox _auto_delete)rL snapshot_idrzr{r<r|r}r~rrrrr?sbs r0sandboxzAsyncSandboxClient.sandboxsZZ&& '-&?/%%'      s !313T) rzr{r<wait_for_readyr|r}r~rrrrr?c nK|r |r tdt|dt|d|jd}d|i}|r||d<|r||d<|r||d<|r||d <|||d<|||d<|||d <| | |d <| | |d <| t| | | |d<| | |d<|r|dznd} |jj ||||j | d {}|jtj|j|dS7:#tj$r}t|d }~wwxYww)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 setr|r}/boxesrrrzr<r{Nr~rrrrrx)jsonr<r?Fclient auto_delete) ValueErrorrrBr#rJpostr]raise_for_statusr from_dictrrHHTTPStatusErrorr)rLrrzr{r<rr|r}r~rrrrr?urlpayload http_timeoutresponsees r0rz!AsyncSandboxClient.create_sandboxYsR =UV V%'9:.0KL ' n#  %0GM " '4GO $ !(GI  "GFO  '*:G& ' $ 03LG/ 0  $GG   #,GK  (+ %'9:.0KLt~~t,"$  &GFO  '*:G& ' $ 03LG/ 0 !ZZ--'4+@+@+I.H  % % ')) %  $$ zz%%,+v[1zz%%,/$XJ.>?"+ %Q '  s=AD3 0B69B4:9B63D34B66D0 A"D++D00D3crKt|j|} |jj||j |d{}|j y7#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~wwxYww)zDelete a Sandbox. Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rNrrrrr) rrBrJdeleter]rrHrrrrrrs r0delete_sandboxz!AsyncSandboxClient.delete_sandboxQst~~t, (!ZZ..T227;/H  % % '$$ (zz%%,+v[1 %Q ' '  (s@B7/A! A A!B7A!!B446B/*B7/B44B7cKt|j|d} |jj||j |d{}|j t j|jS77#tj$r<}|jjdk(rtd|dd|t|d}~wwxYww) 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. statusrNrrrrr)rrBrJrr]rr rrrHrrrrrrs r0get_sandbox_statusz%AsyncSandboxClient.get_sandbox_statusks&t~~tX6 !ZZ^^C9N9Nw9W^XXH  % % '!++HMMO< <Y$$ zz%%,+v[1 %Q '   s:C/B B 6BCBC7CCCiXexpires_in_secondsr?cKttjd}d}d fd } jj ||j d{}|j tj|j|S79#tj$r<} | jjdk(rtdd d | t| d} ~ wwxYww) 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. z service-url)portrcJKjd{S7w)Nr)service)rr?r{rrLsr0 _refresherz.AsyncSandboxClient.service.._refreshers3#5 & s #!#rN)rrrrrr)returnr)rrrBrJrr]rrrrrHrrrrr) rLr{rrr?rrrrrs ````` r0rzAsyncSandboxClient.services< &89t~~t];7IJ   !ZZ__'4+@+@+I-H  % % '",,X]]_T T  $$ zz%%,+v[1 %Q '   s:3C90B'+B%,8B'$C9%B''C6:7C11C66C9)r content_typecontent_dispositionr?cK||dkrtd|dt|j|d}d|i}|||d<|||d<|||d < |jj |||j | d{} | j tj| jS77#tj$r<} | jjd k(rtd |d d| t| d} ~ wwxYww)aMCreate a link that downloads one file from a sandbox. The link carries its own token, so anyone holding the URL can fetch that one file without a LangSmith credential. It is pinned to the sandbox and the exact path and cannot be repointed at another file. 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: name: Sandbox name. 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. Nz/expires_in_seconds must be greater than 0 (got z(); omit it for a link that never expiresz download-urlpathrrrrrrrrr)rrrBrJrr]rrrrrHrrrrr) rLr{rrrrr?rrrrs r0generate_download_urlz(AsyncSandboxClient.generate_download_urls8R  ).@1.D*++SU t~~t^<#)4.  ),>G( )  #&2GN #  *-@G) * !ZZ__'4+@+@+I-H  % % '((9 9  $$ zz%%,+v[1 %Q '   s<AD 0B4:B2;6B41D2B44D7C>>DDxg?)r< poll_intervalr?cKddl}|j|z} |j||d{}|jdk(r|j ||d{S|jdk(rt |j xsdd||jz }|dkrtd |d |d d|j tjt||d{777 w) 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. rNrreadyfailedzSandbox provisioning failedrrr' not ready after sr last_status) time monotonicrrrrstatus_messagerrgsleepmin) rLr{r<rr?rdeadliner remainings r0wait_for_sandboxz#AsyncSandboxClient.wait_for_sandbox s6 >>#g-2242IIF}}'!--dG-DDD}}(+))J-J"+!4>>#33IA~*v%7yB"+ &  --M9 => > >!ID ?s4/C/C))C/C+BC/#C-$C/+C/-C/r<r?cKt|j|d} |jj|i|j |d{}|j |j||| d{S70#t j$r@}|jjdk(rtd|dd|t|Yd}~ld}~wwxYw7\w) 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. startrNrrrrrr) rrBrJrr]rrHrrrrrr)rLr{r<r?rrrs r0 start_sandboxz AsyncSandboxClient.start_sandbox9s,t~~tW5 (!ZZ__"d&;&;G&D-H  % % '**4'*RRR$$ (zz%%,+v[1 %Q ' '  (SsLC0A> A< A> C7C8C<A>>C6C C CCcvKt|j|d} |jj|i|j |d{}|j y7#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~wwxYww) zStop a running sandbox (preserves sandbox files for later restart). Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. stoprNrrrrr) rrBrJrr]rrHrrrrrrs r0 stop_sandboxzAsyncSandboxClient.stop_sandbox_st~~tV4 (!ZZ__"d&;&;G&D-H  % % '$$ (zz%%,+v[1 %Q ' '  (s@B90A# A! A# B9!A##B666B1,B91B66B9<) registry_idr<r?cK|jd}|||d}|||d< |jj|||j|d{} | j t j | j} |j| j||d{S7]#tj$r} t| d} ~ wwxYw7-w)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)r{ docker_imagerNrrr) rBrJrr]rr!rrrHrrwait_for_snapshotid) rLr{rrrr<r?rrrsnapshotrs r0create_snapshotz"AsyncSandboxClient.create_snapshot{s: +(!2#   "%0GM " !ZZ__'4+@+@+I-H  % % '))(--/:H ++ KK',    $$  $Q '   sFC0B0B.7B0!C)C*C.B00C CCC.)context build_argstarget on_build_logr~rr<r?c (Kt||\} } dtjjdd}dtjjdd}t j |d}t j |d}dtjj}t j |d}t j |d }|j || || || d{4d{}|j|tjt| d{| | d{|jd |zd z|zdz|zdz|z| | d{|jt|| |||||| ||| d{}|jdk7r tdd|j|j |||| | d{cdddd{S777777d7!7#1d{7swYyxYww)aBuild a snapshot from a local Dockerfile context. When ``fs_capacity_bytes`` is omitted, the server applies its default. ``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)r{r<r~rrr?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 posixpathjoinrwriterg to_threadrrunr exit_codercapture_snapshotr{)rLr{ dockerfilerrrrrr~rr<r? context_pathr builder_name build_rootr remote_tarrrrrresults r0create_snapshot_from_dockerfilez2AsyncSandboxClient.create_snapshot_from_dockerfilesr.(C:w'W$ n*4::<+;+;CR+@*AB 11A1A#21F0GH " I>^^J > / 0@0@/AB !z?C  ~~j.A / &    --''(@,OO     ++ !!"!!! !    !!    #;;.#1#1'"/!-)! &&'F1$+6",.. &"3 /_    P  (_    sC+H-G-.H6G/7H:*G=$G1 %G=3G340G=$G5%-G=G7AG=G9G= H'G;(H/H1G=3G=5G=7G=9G=;H=HH H Hrc&Kt|j|d}d|i}|||d<|||d< |jj|||j |d{} | j t j| j} |j| j || d{S7]#tj$r<} | jjdk(rtd|d d | t| d} ~ wwxYw7Xw) 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. rr{Nrrrrrrrrr)rrBrJrr]rr!rrrHrrrrrrr) rL sandbox_namer{rrr<r?rrrrrs r0rz#AsyncSandboxClient.capture_snapshots$8t~~|Z@#)4.  #&2GN #  (+= 0``. Useful for paginating through large result sets in combination with ``limit``. Returns: A single page of Snapshots matching the provided filters. rNr r r)paramsr? snapshotsrrr)rBrJrr]rrr!rrHrrrrr) rLr r rr?rrrrrrs r0list_snapshotsz!AsyncSandboxClient.list_snapshotsas.< +!#  $&3F? #  #F7O  %F8  !ZZ^^~--g6,H  % % '==?D3788K3LM3LaH&&q)3LM MN$$ zz%%,%.se4:; %Q '  sL'D 4B=B68B=B83B=5D 6B=8B==D 5DD  D czK|jdt|} |jj||j |d{}|j y7#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~wwxYww) zDelete a snapshot. Args: snapshot_id: Snapshot UUID. Raises: ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. rrNrr rrr) rBrrJrr]rrHrrrrrr s r0delete_snapshotz"AsyncSandboxClient.delete_snapshots ,? ,L+MN (!ZZ..T227;/H  % % '$$ (zz%%,+  [9 %Q ' '  (s@B;/A% A#A%"B;#A%%B886B3.B;3B88B;i,g@cKddl}|j|z} |j||d{}|jdk(r|S|jdk(rt |j xsdd||jz }|dkrt d |d |d d|j tjt||d{77w) 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. rNrrrzSnapshot build failedrrr rrr) rrr rrrrrgrr) rLrr<rr?rrrrs r0rz$AsyncSandboxClient.wait_for_snapshots0 >>#g-!..{G.LLH')(*+++F/F",!4>>#33IA~*  -?yJ", ( --M9 => > >!L ?s"/CCBC C CC) r; Optional[str]r<floatr=rr>intr?Optional[Mapping[str, str]]rstr)rr&)r?RequestHeadersrzOptional[dict[str, str]])rr )rNone)rr8)rqzOptional[type]rrzOptional[BaseException]rsz Optional[Any]rr)N)rrrzrr{rr<rr| Optional[int]r}rr~rrrrrrOptional[SandboxMountConfig]rOptional[SandboxProxyConfig]r?rrr )rrrzrr{rr<rrboolr|rr}rr~rrrrrrrrr r?rrr )r{rr?rrr )r?rrzlist[AsyncSandbox]) r{rrrr|rr}rr?rrr )r{rr?rrr)r{rr?rrr ) r{rrrrrr?rrr)r{rrrrrrrrz$Optional[DownloadContentDisposition]r?rrr) r{rr<rrrr?rrr )r{rr<rr?rrr )r{rrrrrrrr<rr?rrr!)r{rrUnion[str, os.PathLike[str]]rrrr"rrrrrzOptional[Callable[[str], Any]]r~rrrr<rr?rrr!)rrr{rrrrrr<rr?rrr!)rrr?rrr!) r rr rrrr?rrzlist[Snapshot])rrr?rrr) rrr<rrrr?rrr!)#__name__ __module__ __qualname____doc__rOrTpropertyrYr]r_rarcrmrortrwrrrrrrrrrrrrrrrr rrrr5r2r0r8r8Lsn  '+!%/3(A$(A (A  (A  (A-(AT<<8: = $2 $ )   A&*\(,"*.37##'+/5959"&\"\% \  \  \(\$1\\!\)\3\3\ \ \@&*z(,"#*.37##'+/5959"&z"z% z  z  zz(z$1zz!z)z3z3z z !zz7;%3 D,0( >#'*.37"&>> > ( > $1 > > >B7;((%3( (67;%3 L#&"& 666  6  6 6z-1&*DH"&CCC * C $ CBC C CR""& .?.? .?  .?  .? .?h"& $S$S $S  $S  $SLJN(D&*"&3 3 3  3 # 3 3  3  3 r,0 \ 1426 $7;##'"&\\1\) \ . \0\\5\\!\\ \ \F'++/"&4 4 4 $ 4 ) 4 4  4  4 n>B,: @(,# $"& 8%8 8  8  8 8v>B((,:( (<""& +?+? +?  +?  +? +?r2r8r)rr)>r& __future__rrgosrrcollections.abcrrtypingrrrr rH langsmithr r,langsmith._openapi_clientr langsmith.sandbox._async_sandboxr langsmith.sandbox._clientr rrrrrlangsmith.sandbox._exceptionsrrrrrlangsmith.sandbox._helpersrrrrrlangsmith.sandbox._modelsrrrr r!langsmith.sandbox._mountsr"r#langsmith.sandbox._proxy_configr$langsmith.sandbox._transportr%8langsmith._openapi_client.resources.sandboxes.registriesr&r1r6rrr8r5r2r0r7sL"  -66 '49?< .+ '#s(+,T?T?r2