jxdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZmZmZmZddlmZddlZddlmZdd lmZdd lmZmZmZmZm 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 l-m.Z.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5er ddl6m7Z7ddl8m9Z9ddZ:ddZ;ee eddZ?d dZ@ d!dZA d"dZBGddZCy)#zEMain SandboxClient class for interacting with the sandbox server API.) annotationsN)CallableMapping)Path) TYPE_CHECKINGAnyOptionalUnion)quote)utils) Langsmith)ResourceCreationErrorResourceNameConflictErrorResourceNotFoundErrorResourceTimeoutErrorSandboxAPIError)handle_client_http_errorhandle_sandbox_creation_error merge_headersvalidate_service_params validate_ttl)DownloadContentDisposition DownloadURLResourceStatus ServiceURLSnapshot)SandboxMountConfig"validate_mount_config_proxy_config)SandboxProxyConfig)Sandbox)RetryTransport)RegistriesResourceAsyncSandboxClientcXtjdd}|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 c/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/sandbox/_client.py_get_default_api_endpointr/8s.    4U VDkk# } --c,tjdS)z)Get the default API key from environment.API_KEY)r*r+r0r._get_default_api_keyr4As    **r0c6|s tdt|dS)zCQuote a user-controlled value for use as a single URL path segment.z+URL path segment must be a non-empty string)safe) ValueErrorr )values r._quote_path_segmentr:Is FGG R  r0cV|rddj|znd}|dt||S)zDBuild the URL for a sandbox, optionally with trailing path segments.r(r6z/boxes/)joinr:)base_urlnamesegmentssuffixs r._box_urlrAPs5)1S388H% %rFZw2489& BBr0ctj}tj|d5}t |j dD]T}|j |}|jr|jddk(r3|j||jdV ddd|jS#1swY|jSxYw)Nw)fileobjmode*rz.gitF)arcname recursive) ioBytesIOtarfileopensortedrglob relative_topartsaddas_posixgetvalue) context_pathbuftarpathrels r._make_docker_context_tarrYVs **,C c ,<--c23D""<0CyySYYq\V3 GGD#,,.EG B 4 - <<> - <<>s A2B77Cct|jj}t|j}|js||z }|j}|j st d||j st d| |j|}||jfS#t $r}t d|d}~wwxYw)Nzcontext must be a directory: zdockerfile must be a file: z!dockerfile must be inside context) r expanduserresolve is_absoluteis_dirr8is_filerOrR) dockerfilecontextrTdockerfile_pathdockerfile_relexcs r._resolve_dockerfile_contextreas=++-557L:&113O  & & (&8%--/O    8GHH  " " $66GHIIG(44\B 002 22 G<=3FGs#C C  CC cvtj||}tj|}tj|} tj|d} ddd| zddddd d |zd d |zd d | zdd|zg} || j d d|zgt |xsij D]\} } | j d d| d| g dtj|dtj|dtjd| zdtj|dtj|dzdtjd| zdtj|dzdtj|dzdtj| dtj|dS)Nzbuildkitd.sockbuildctlz--addrzunix://buildz--progress=plainz --frontendz dockerfile.v0z--localzcontext=z dockerfile=z--optz filename=z--outputztype=docker,name=ztarget=z build-arg:=zset -euo pipefail mkdir -p  z buildkitd --addr z --root zq --oci-worker=true --containerd-worker=false --oci-worker-snapshotter=native --oci-worker-binary buildkit-runc > z/buildkitd.logz 2>&1 & buildkitd_pid=$! cleanup() { kill "$buildkitd_pid" >/dev/null 2>&1 || true; } trap cleanup EXIT for i in $(seq 1 300); do if buildctl --addr zi debug workers >/dev/null 2>&1; then break; fi if ! kill -0 "$buildkitd_pid" >/dev/null 2>&1; then cat z+; exit 1; fi if [ "$i" = 300 ]; then cat z; exit 1; fi sleep 0.1 done for i in $(seq 1 300); do if docker info >/dev/null 2>&1; then break; fi if [ "$i" = 300 ]; then docker info; exit 1; fi sleep 0.1 done z | docker load rm -rf z || true ) posixpathr<dirnamebasenameextendrMitemsshlexr )remote_contextrc image_ref buildkit_root buildkit_run build_argstargetdockerfile_remotedockerfile_dirdockerfile_name socket_pathrgkeyr9s r._make_dockerfile_build_commandr|us"~~F&&'89N(():;O../?@KK^#&o%i'H")f"456j.B5578 UJse1UG"<=>9 KK ./q\1J0KL!KK K(?@AB++m,-. [[(88 9 :; !& I ,C DEF{{<*::;<={{<*::;<= ::h  !++m,-Z5 9r0ceZdZdZdddddd d9dZd:dZed;dZdd Z d>d Z d?dZ d@dZd:dZ dAdddddddddddd dBdZ dAddddddddddddd dCdZdddDdZdddEdZddddd dFdZdddGdZdd 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)T SandboxClientaClient for interacting with the Sandbox Server API. This client provides a simple interface for managing sandboxes and snapshots. Example: # Uses LANGSMITH_ENDPOINT and LANGSMITH_API_KEY from environment client = SandboxClient() # Or with explicit configuration client = SandboxClient( api_endpoint="https://api.smith.langchain.com/v2/sandboxes", api_key="your-api-key", ) # Create a sandbox with the default runtime and run commands with client.sandbox() as sandbox: result = 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 SandboxClient. 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) transportrrN)r/r, _base_urlr4_api_key_timeout _max_retriesdict_default_headersrr!httpxClient_http_registries_client) selfrrrrrresolved_api_keyclient_headersrs r.__init__zSandboxClient.__init__s2'E*C*EMMcR"<&:&<(  'AHW b)+ *:N; '  *>4;P;PQN"{; \\.  8<r0cd}|jj|r|jdt| S|jS)z>Return the API root URL, without the ``/v2/sandboxes`` suffix.r)N)rendswithlen)rr@s r. _api_rootzSandboxClient._api_roots:  >> " "6 *>>.S[L1 1~~r0c|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 = client.registries.create( name="internal", url="registry.example.com", username="robot", password=os.environ["REGISTRY_PASSWORD"], ) snapshot = 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)rr=default_headers)rr rrr sandboxes registriesrs r.rzSandboxClient.registriessV*  " " *&/ ) $ 5 5 ='D # &&00;;;r0cH|yt|jj|S)z8Merge default client headers with per-request overrides.N)rrrrrs r._request_headerszSandboxClient._request_headerss! ?TZZ//99r0cL|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)rrrs r._ws_default_headersz!SandboxClient._ws_default_headers s' $$T22G<s5   " " .  # # ) ) + /r0c |jjs|jj|j|jjyy#t$rYywxYw)z,Close the HTTP client on garbage collection.N)r is_closedrr Exceptionrs r.__del__zSandboxClient.__del__DsY ::''   "&&2''--/3   sAA A&%A&c|S)zEnter context manager.r3rs r. __enter__zSandboxClient.__enter__Ns r0c$|jy)zExit context manager.N)r)rexc_typeexc_valexc_tbs r.__exit__zSandboxClient.__exit__Rs  r0c"d|jdS)zReturn a string representation of the instance. Returns: The string representation of the instance. zSandboxClient (API URL: ))rrs r.__repr__zSandboxClient.__repr__[s *$..)9;;r0 snapshot_namer>ridle_ttl_secondsdelete_after_stop_secondsvcpus mem_bytesfs_capacity_bytes mount_config proxy_configrc N|j||||||||| | | |  } d| _| S)a Create a sandbox and return a Sandbox instance. This is the primary method for creating sandboxes. Use it as a context manager for automatic cleanup: with client.sandbox(snapshot_id="") as sandbox: result = sandbox.run("echo hello") # Resolve by snapshot name instead of ID: with client.sandbox(snapshot_name="my-snap") as sandbox: result = 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: Sandbox 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. rT)create_sandbox _auto_delete)r snapshot_idrr>rrrrrrrrrsbs r.sandboxzSandboxClient.sandboxgsLZ '-&?/%%!   r0T) rr>rwait_for_readyrrrrrrrrc R|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 | }|jtj|j|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 Sandbox. 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/boxesrrrrr>Nrrrrrr)jsonrrFclient auto_delete)r8rrrrpostrraise_for_statusr from_dictrrHTTPStatusErrorr)rrrr>rrrrrrrrrrurlpayload http_timeoutresponsees r.rzSandboxClient.create_sandboxsR =UV V%'9:.0KL ' n#  %0GM " '4GO $ !(GI  "GFO  '*:G& ' $ 03LG/ 0  $GG   #,GK  (+rrrrs r. get_sandboxzSandboxClient.get_sandbox?st~~t, zz~~c43H3H3Q~RH  % % '$$X]]_TuU U$$ zz%%,+v[1 %Q '   sA!A::C  7CC c|jd} |jj||j|}|j |j }|jdgDcgc]}t j||dc}Scc}w#tj$r:}|jjdk(rtd|d|t|d }~wwxYw) zMList all Sandboxes. Returns: List of Sandboxes. rrrFrrAPI endpoint not found: %. Check that api_endpoint is correct.N)rrrrrrr rrrrrrr)rrrrdatacrs r.list_sandboxeszSandboxClient.list_sandboxes\s  ' zz~~c43H3H3Q~RH  % % '==?D+r22A!!!DeD2 $$ zz%%,%.se4:; %Q '  s*A B1BBBC%+5C  C%)new_namerrrcNt|dt|dt|j|}i}|||d<|||d<|||d< |jj |||j |}|j tj|j|dS#tj$rg} | jjdk(rtd |d d | | jjd k(rtd|dd | t!| d} ~ wwxYw)a]Update 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 Sandbox. Raises: ResourceNotFoundError: If sandbox not found. ResourceNameConflictError: If new_name is already in use. SandboxClientError: For other errors. ValueError: If TTL values are invalid. rrNr>rrFrrrrrrizSandbox name 'z' already in use)rrArrpatchrrr rrrrrrrrr) rr>rrrrrrrrs r.update_sandboxzSandboxClient.update_sandboxusD> %'9:.0KLt~~t,"$  &GFO  '*:G& ' $ 03LG/ 0 zz'''4+@+@+I(H  % % '$$X]]_TuU U$$ zz%%,+v[1zz%%,/$XJ.>?"+ %Q '  sA"B**D$=A"DD$cVt|j|} |jj||j |}|j y#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~wwxYw)zDelete a Sandbox. Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rrrrrrN) rArrdeleterrrrrrrrrs r.delete_sandboxzSandboxClient.delete_sandboxst~~t, (zz((d6K6KG6T(UH  % % '$$ (zz%%,+v[1 %Q ' '  (srrsr. _refresherz)SandboxClient.service.._refresher s%<<#5   r0r)rrrrrrN)returnr)rrArrrrrrrrrrrrrr) rr>rrrrrrrrs ````` r.rzSandboxClient.services: &89t~~t];7IJ   zz'4+@+@+I'H  % % ''' JO O$$ zz%%,+v[1 %Q '   sA!BC*.7C%%C*)r content_typecontent_dispositionrc||dkrtd|dt|j|d}d|i}|||d<|||d<|||d < |jj |||j | } | j tj| jS#tj$r<} | jjd k(rtd |d d| t| d} ~ wwxYw)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-urlrWrrrrrrrrr)r8rArrrrrrrrrrrrrr) rr>rWrrrrrrrrs r.generate_download_urlz#SandboxClient.generate_download_url!s)R  ).@1.D*++SU t~~t^<#)4.  ),>G( )  #&2GN #  *-@G) * zz'4+@+@+I'H  % % '((9 9$$ zz%%,+v[1 %Q '   sAB((C7;7C22C7xg?)r poll_intervalrcddl}|j|z} |j||}|jdk(r|j ||S|jdk(rt |j xsdd||jz }|dkrtd |d |d d|j |jt||) 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: Sandbox 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_messagersleepmin) rr>rrrr deadliner remainings r.wait_for_sandboxzSandboxClient.wait_for_sandboxfs6 >>#g-,,T7,CF}}'''g'>>}}(+))J-J"+!4>>#33IA~*v%7yB"+ &  JJs=)4 5!r0rrct|j|d} |jj|i|j |}|j |j||| S#t j$r@}|jjdk(rtd|dd|t|Yd}~bd}~wwxYw) aStart a stopped sandbox and wait until ready. Args: name: Sandbox name. timeout: Timeout in seconds when waiting for ready. Returns: Sandbox 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. startrrrrrrNr) rArrrrrrrrrrrr)rr>rrrrrs r. start_sandboxzSandboxClient.start_sandboxs,t~~tW5 (zz"d&;&;G&D'H  % % '$$T7G$LL$$ (zz%%,+v[1 %Q ' '  (s=A**B==6B88B=cZt|j|d} |jj|i|j |}|j y#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~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. stoprrrrrrN) rArrrrrrrrrrrrs r. stop_sandboxzSandboxClient.stop_sandboxst~~tV4 (zz"d&;&;G&D'H  % % '$$ (zz%%,+v[1 %Q ' '  (s=AB**6B%%B*<) registry_idrrc|jd}|||d}|||d< |jj|||j|} | j t j | j} |j| j||S#tj$r} t| d} ~ wwxYw)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) rrrrrrrrrrrwait_for_snapshotid) rr>rrrrrrrrsnapshotrs r.create_snapshotzSandboxClient.create_snapshots: +(!2#   "%0GM " zz'4+@+@+I'H  % % '))(--/:H %%hkk7G%TT $$  $Q '  sA BC/ B;;C.)rarurv on_build_logrrrrc t||\} } dtjjdd}dtjjdd}t j |d}t j |d}dtjj}t j |d}t j |d }|j || || || 5}|j|t| | | |jd tj|zd ztj|zdztj|zdztj|z| | |jt|| |||||| ||| }|jdk7r tdd|j|j |||| | cdddS#1swYyxYw)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/raz context.tarzlangsmith-snapshot-build:z buildkit-rootz buildkit-run)r>rrrrrrzrm -rf z && mkdir -p z && tar -xf z -C )rqrcrrrsrtrurv)r on_stdout on_stderrrrz Dockerfile snapshot build failedrrrrrr)reuuiduuid4hexrkr<rwriterYrunrpr r| exit_codercapture_snapshotr>)rr>r`rrarurvr"rrrrrTrc builder_name build_rootrq remote_tarrrrsrtrresults r.create_snapshot_from_dockerfilez-SandboxClient.create_snapshot_from_dockerfile s.(C:w'W$ n*4::<+;+;CR+@*AB 11A1A#21F0GH " I>^^J > / 0@0@/AB !z?C  ~~j.A \\/   MM(6   KK++n-.!"++n-.! ! ++j) *  ++n-.   [[.#1#1'"/!-)! &&!F1$+6",(( &"3 )_   s (C6G((G1r'ct|j|d}d|i}|||d<|||d< |jj|||j |} | j t j| j} |j| j || S#tj$r<} | jjdk(rtd|d d | t| d} ~ wwxYw) afCapture 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. docker_image: Optional Docker image tag inside the sandbox to export into the snapshot instead of capturing the live root filesystem. fs_capacity_bytes: Filesystem capacity in bytes for Docker image export. 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)rArrrrrrrrrrrrrrrr) r sandbox_namer>rrrrrrrrrs r.r.zSandboxClient.capture_snapshotis>t~~|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)rrrrrrrrrrrrrr) rr;r<r=rrr?rrrrs r.list_snapshotszSandboxClient.list_snapshotss< +!#  $&3F? #  #F7O  %F8  zz~~~--g6&H  % % '==?D3788K3LM3LaH&&q)3LM MM$$ zz%%,%.se4:; %Q '  s*A%B1 B,)B1,B11C>5C99C>c^|jdt|} |jj||j |}|j y#t j$r@}|jjdk(rtd|dd|t|Yd}~yd}~wwxYw) zDelete a snapshot. Args: snapshot_id: Snapshot UUID. Raises: ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. r7rrr8rrrN) rr:rrrrrrrrrrr9s r.delete_snapshotzSandboxClient.delete_snapshots ,? ,L+MN (zz((d6K6KG6T(UH  % % '$$ (zz%%,+  [9 %Q ' '  (s>#g-((g(FH')(*+++F/F",!4>>#33IA~*  -?yJ", ( JJs=)4 5!r0) r Optional[str]rfloatrrErintrzOptional[RequestHeaders]rstr)rr")rRequestHeadersrzOptional[dict[str, str]])rr$)rNone)rr~)rzOptional[type]rzOptional[BaseException]rz Optional[Any]rrK)N)rrErrEr>rErrGr Optional[int]rrLrrLrrLrrLrOptional[SandboxMountConfig]rOptional[SandboxProxyConfig]rrJrr )rrErrEr>rErrGrboolrrLrrLrrLrrLrrLrrMrrNrrJrr )r>rIrrJrr )rrJrz list[Sandbox]) r>rIrrErrLrrLrrJrr )r>rIrrJrrK)r>rIrrJrr) r>rIrrGrrGrrJrr)r>rIrWrIrrLrrErz$Optional[DownloadContentDisposition]rrJrr) r>rIrrGrrFrrJrr )r>rIrrGrrJrr )r>rIrrIrrGrrErrGrrJrr)r>rIr`Union[str, os.PathLike[str]]rrLrarPruOptional[Mapping[str, str]]rvrEr"zOptional[Callable[[str], Any]]rrLrrLrrGrrJrr)r5rIr>rIrrErrLrrGrrJrr)rrIrrJrr) r;rEr<rLr=rLrrJrzlist[Snapshot])rrIrrJrrK) rrIrrGrrFrrJrr)#__name__ __module__ __qualname____doc__rrpropertyrrrrrrrrrrrrrrrrrrrrrr r3r.r:rArCrr3r0r.r~r~s:.'+!%,0(<$(< (<  (<  (<*(B,: @(,# $"& 8%8 8  8  8 8v>B((,:( (8""& +6+6 +6  +6  +6 +6r0r~rH)rrE)r9rIrrI)r=rIr>rIr?rIrrI)rTrrbytes)r`rPrarPrztuple[Path, str])rqrIrcrIrrrIrsrIrtrIrurQrvrErrI)DrU __future__rrIosrkrprKr(collections.abcrrpathlibrtypingrrr r urllib.parser r langsmithr r*langsmith._openapi_clientr langsmith.sandbox._exceptionsrrrrrlangsmith.sandbox._helpersrrrrrlangsmith.sandbox._modelsrrrrrlangsmith.sandbox._mountsrrlangsmith.sandbox._proxy_configrlangsmith.sandbox._sandboxr langsmith.sandbox._transportr!8langsmith._openapi_client.resources.sandboxes.registriesr"rr$r/r4rIrJr:rArYrer|r~r3r0r.rhsK"   -66 '/?.7C.+ '#s(+,!C 3,3 )33(??? ?  ?  ?,? ? ?DC6C6r0