ޠjSrSSKJr SSKrSSKrSSKrSSKrSSKJrJ r SSK J r J r J r Jr SSKJr SSKJr SSKJr SS KJr SS KJrJrJrJrJrJrJr SS K J!r!J"r"J#r#J$r$J%r% SS K&J'r'J(r(J)r)J*r*J+r+ SS K,J-r-J.r.J/r/J0r0J1r1J2r2 SSK3J4r4J5r5 SSK6J7r7 SSK8J9r9 \ (aSSK:J;r; SSjr\>4r?"SS5r@g)zFAsync SandboxClient class for interacting with the sandbox server API.) annotationsN)CallableMapping) TYPE_CHECKINGAnyOptionalUnion)utils)AsyncLangsmith)httpx) AsyncSandbox) SandboxClient_box_url_make_docker_context_tar_make_dockerfile_build_command_quote_path_segment_quote_reference_segment_resolve_dockerfile_context)ResourceCreationErrorResourceNameConflictErrorResourceNotFoundErrorResourceTimeoutErrorSandboxAPIError)handle_client_http_errorhandle_sandbox_creation_error merge_headersvalidate_service_params validate_ttl)AsyncServiceURLDownloadContentDisposition DownloadURLResourceStatusSnapshot SnapshotTag)SandboxMountConfig"validate_mount_config_proxy_config)SandboxProxyConfig)AsyncRetryTransport)AsyncRegistriesResourcecT[R"SSS9nURS5S3$)z~Get 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 Y/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/sandbox/_async_client.py_get_default_api_endpointr4<s.    4U VDkk# } --c.[R"S5$)z)Get the default API key from environment.API_KEY)r/r0r5r3_get_default_api_keyr9Es    **r5cF\rSrSrSrSSSSSS.SS j5rS?S jr S?S jr S@S jr SAS jr SASjr SBSjrSCSjrS=SjrSDSSSSSSSSSSSSS. SESjjjrSDSSSSSSSSSSSSSS. SFSjjjrSS.SGSjjrSS.SHSjjrSSSSS.SISjjrSS.SJSjjrSS.SKSjjrSSS .SLS!jjrSSSSS".SMS#jjrS$S%SS&.SNS'jjrS$SS(.SOS)jjrSS.SJS*jjrSSS+SS,.SPS-jjrSDS.SSSSSS+SS/.SQS0jjjrSSSS+SS1.SRS2jjrSS.SSS3jjr SS.STS4jjr!SSSSS5.SUS6jjr"SS.SVS7jjr#S8S9SS&.SWS:jjr$S;r%g)XAsyncSandboxClientMaAsync 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_retriesheaderscU=(d [5RS5UlU=(d [5nX`lX lX@lU(a [U5O0Ul0nU(aXgS'UR(a[XpR5n[US9n[R"XUS9Ul SUlg)a>Initialize 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)rB) transportr@rCN)r4r1 _base_urlr9_api_key_timeout _max_retriesdict_default_headersrr(r AsyncClient_http_registries_client) selfr?r@rArBrCresolved_api_keyclient_headersrEs r3__init__AsyncSandboxClient.__init__[s2'E*C*EMMcR"<&:&<(  'AHW b)+ *:; '  *>;P;PQN'K@ &&.  =Ar5cSnURRU5(aURS[U5*$UR$)z>Return the API root URL, without the ``/v2/sandboxes`` suffix.r.N)rFendswithlen)rOsuffixs r3 _api_rootAsyncSandboxClient._api_roots=  >> " "6 * *>>.S[L1 1~~r5cURc;[URUR5UR=(d SS9UlURR R $)arManage 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)rAbase_urldefault_headers)rNr rGrXrK sandboxes registriesrOs r3r^AsyncSandboxClient.registriessV*  " " *&4 ) $ 5 5 ='D # &&00;;;r5cJUcg[URRU5$)z8Merge default client headers with per-request overrides.N)rrMrCrOrCs r3_request_headers#AsyncSandboxClient._request_headerss! ?TZZ//99r5cXUR(dUcg[URU5$)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)rKrrbs r3_ws_default_headers&AsyncSandboxClient._ws_default_headerss' $$T22G<)rrFrHrGrIrKr_s r3to_syncAsyncSandboxClient.to_syncs=MMMM))))1T   r5c# URR5IShvN URb#URR5IShvN ggN5N7f)zClose the async HTTP client.N)rMacloserNcloser_s r3rlAsyncSandboxClient.aclosesLjj!!!  " " .))//1 1 1 / " 1s!AA.AAAAcURR(dL[R"5nUR5(d UR UR 55 ggg![ a gf=f![a gf=f)aBest-effort cleanup of the async HTTP client on garbage collection. If an event loop is running, schedules ``aclose()`` as a task. Otherwise the underlying sockets will be closed by the GC. For deterministic cleanup, use ``async with`` or ``await aclose()``. N)rM is_closedasyncioget_running_loop create_taskrl RuntimeError Exception)rOloops r3__del__AsyncSandboxClient.__del__sw ::''"335D>>++((7,( $   s/A:A A** A74A:6A77A:: BBc# U$7f)zEnter async context manager.r8r_s r3 __aenter__AsyncSandboxClient.__aenter__s  sc@# UR5IShvN gN7f)zExit async context manager.N)rl)rOexc_typeexc_valexc_tbs r3 __aexit__AsyncSandboxClient.__aexit__skkms c"SURS3$)ziReturn a string representation of the instance. Returns: The string representation of the instance. zAsyncSandboxClient (API URL: ))rFr_s r3__repr__AsyncSandboxClient.__repr__s /t~~.>a@@r5 snapshot snapshot_namenamer@idle_ttl_secondsdelete_after_stop_secondsvcpus mem_bytesfs_capacity_bytes mount_config proxy_configrCc f# URUUUUUUUUU U U U U S9 IShvN nSUlU$N 7f)ad 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`` and ``snapshot_name``. snapshot: Snapshot to boot from, as a UUID, ``name:tag``, or a bare ``name`` (which means ``name:latest``). Prefer this over ``snapshot_id`` and ``snapshot_name``: it covers all three forms. snapshot_name: Deprecated synonym for ``snapshot``, kept for callers that predate it. 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 more than one of ``snapshot_id``, ``snapshot`` and ``snapshot_name`` is provided. rNT)create_sandbox _auto_delete)rO snapshot_idrrrr@rrrrrrrrCsbs r3sandboxAsyncSandboxClient.sandboxs\`&& '-&?/%%'   ! s 1/1T) rrrr@wait_for_readyrrrrrrrrCc $# U=(d UnU(aU(aX#:wa [S5eU(aU(a [S5e[US5 [US5 URS3nSU0nU(aUUS'U(aUUS'O U(aUUS 'U(aUUS 'U(aUUS 'UbUUS'UbUUS'U bU US 'U bU US'U bU US'U b[X5 U US'U bU US'U(aUS-OSnURR UUUUR U5S9IS hvN nUR5 [R"UR5USS9$N8![Ran[U5 eS nAff=f7f)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`` and ``snapshot_name``. snapshot: Snapshot to boot from, as a UUID, ``name:tag``, or a bare ``name`` (which means ``name:latest``). Prefer this over ``snapshot_id`` and ``snapshot_name``: it covers all three forms. snapshot_name: Deprecated synonym for ``snapshot``, kept for callers that predate it. 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. z,snapshot and snapshot_name must not disagreez@At most one of snapshot_id, snapshot or snapshot_name may be setrr/boxesrrrrr@rNrrrrrr)jsonr@rCFclient auto_delete) ValueErrorrrFr&rMpostrcraise_for_statusr from_dictrr HTTPStatusErrorr)rOrrrrr@rrrrrrrrrC referenceurlpayload http_timeoutresponsees r3r!AsyncSandboxClient.create_sandbox^sX-  (*CKL L 9R  %'9:.0KL ' n#  %0GM " "*GJ  '4GO $ !(GI  "GFO  '*:G& ' $ 03LG/ 0  $GG   #,GK  (+7B=C>BC5C  CCc # URS3nURRX RU5S9IShvN nUR 5 UR 5nURS/5Vs/sHn[ R"XPSS9PM sn$NYs snf![Ra;nURRS:Xa[SUS 35Ue[U5 eSnAff=f7f) z:List all Sandboxes. Returns: List of AsyncSandboxes. rrNr]FrrAPI endpoint not found: %. Check that api_endpoint is correct.)rFrMrrcrrr rr rrrrr)rOrCrrdatacrs r3list_sandboxes!AsyncSandboxClient.list_sandboxess ' !ZZ^^C9N9Nw9W^XXH  % % '==?D+r22A&&q5I2 Y$$ zz%%,%.se4:; %Q '  sJC1+BB8B7BBC1BBC.36C))C..C1)new_namerrrCcX# [US5 [US5 [URU5n0nUbX'S'UbX7S'UbXGS'URR XgUR U5S9IShvN nUR 5 [R"UR5USS9$N8![Racn U RRS:Xa[S US 3S S 9U eU RRS :Xa[SUS3S S 9U e[!U 5 eSn A ff=f7f)aUpdate 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. rrNrrrCFrrrrrrizSandbox name 'z' already in use)rrrFrMpatchrcrr rrr rrrrrr) rOrrrrrCrrrrs r3update_sandbox!AsyncSandboxClient.update_sandbox sO> %'9:.0KLt~~t,"$  &FO  '*:& ' $ 03L/ 0 !ZZ--4+@+@+I.H  % % ')) %  $$ zz%%,+v[1zz%%,/$XJ.>?"+ %Q '  s=AD* ,B05B.67B0-D*.B00D'AD""D''D*ch# [URU5nURRX0R U5S9IShvN nUR 5 gN![ Ra>nURRS:Xa[SUS3SS9Ue[U5 SnAgSnAff=f7f)zDelete a Sandbox. Args: name: Sandbox name. Raises: ResourceNotFoundError: If sandbox not found. SandboxClientError: For other errors. rNrrrrr) rrFrMdeletercrr rrrrrrs r3delete_sandbox!AsyncSandboxClient.delete_sandbox`st~~t, (!ZZ..227;/H  % % '$$ (zz%%,+v[1 %Q ' '  (s@B2+AAAB2AB/14B*%B2*B//B2c# [URUS5nURRX0R U5S9IShvN nUR 5 [ R"UR55$N8![Ra:nURRS:Xa[SUS3SS9Ue[U5 eSnAff=f7f) 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)rrFrMrrcrr"rrr rrrrrrs r3get_sandbox_status%AsyncSandboxClient.get_sandbox_statuszs&t~~tX6 !ZZ^^C9N9Nw9W^XXH  % % '!++HMMO< <Y$$ zz%%,+v[1 %Q '   s:C+BA?7B>C?BC5C  CCiXexpires_in_secondsrCc^^^^^# [TT5 [TRTS5nTTS.nS UUUUU4SjjnTRR XVTR T5S9IShvN nUR 5 [R"UR5US9$N7![Ra:n U RRS:Xa[STS 3S S 9U e[U 5 eSn A ff=f7f) 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)portrcD># TRTTTTS9IShvN $N7f)Nr)service)rrCrrrOsr3 _refresher.AsyncSandboxClient.service.._refreshers2#5 & s   rN)rrrrrr)returnr)rrrFrMrrcrrrrr rrrrr) rOrrrrCrrrrrs ````` r3rAsyncSandboxClient.services< &89t~~t];7IJ   !ZZ__4+@+@+I-H  % % '",,X]]_T T  $$ zz%%,+v[1 %Q '   s:5C4,B#)B!*6B# C4!B##C175C,,C11C4)r content_typecontent_dispositionrCc # UbUS:a[SUS35e[URUS5nSU0nUbX8S'UbXHS'UbXXS 'URR XxUR U5S 9IShvN n U R 5 [R"U R55$N8![Ra:n U RRS :Xa[S US 3SS9U e[U 5 eSn A ff=f7f)aCreate 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)rrrFrMrrcrr!rrr rrrrr) rOrrrrrrCrrrrs r3generate_download_url(AsyncSandboxClient.generate_download_urls/R  ).@1.D*++SU t~~t^<#)4.  ),>( )  #&2N #  *-@) * !ZZ__4+@+@+I-H  % % '((9 9  $$ zz%%,+v[1 %Q '   s<A D ,B38B197B30D1B33D5C<<DDxg?)r@ poll_intervalrCc# SSKnUR5U-nURXS9IShvN nURS:XaUR XS9IShvN $URS:Xa[ UR =(d SSS9eXeR5- nUS::a[S US US 3SURS 9e[R"[X855IShvN MNNN 7f) a<Poll 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_messagerrqsleepmin) rOrr@rrCrdeadliner remainings r3wait_for_sandbox#AsyncSandboxClient.wait_for_sandboxs6 >>#g-2242IIF}}'!--d-DDD}}(+))J-J"+!>>#33IA~*v%7yB"+ &  --M => > >!ID ?s4+C)C#&C)C%BC)C'C)%C)'C)r@rCc# [URUS5nURRU0UR U5S9IShvN nUR 5 URXUS 9IShvN $N,![ Ra>nURRS:Xa[SUS3SS9Ue[U5 SnANgSnAff=fN[7f) 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) rrFrMrrcrr rrrrrr)rOrr@rCrrrs r3 start_sandbox AsyncSandboxClient.start_sandboxHs,t~~tW5 (!ZZ__"d&;&;G&D-H  % % '**4'*RRR$$ (zz%%,+v[1 %Q ' '  (SsLC-A7A5 A7C0C 1C5A77C  4C?CC  Ccn# [URUS5nURRU0UR U5S9IShvN nUR 5 gN![ Ra>nURRS:Xa[SUS3SS9Ue[U5 SnAgSnAff=f7f) 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) rrFrMrrcrr rrrrrrs r3 stop_sandboxAsyncSandboxClient.stop_sandboxnst~~tV4 (!ZZ__"d&;&;G&D-H  % % '$$ (zz%%,+v[1 %Q ' '  (s@B5-A A A B5A B244B-(B5-B22B5<)tag registry_idr@rCc# URS3nUUUS.n UbXIS'UbXYS'URRXURU5S9IShvN n U R 5 [ R "U R55n URU RXgS9IShvN $NZ![Ran [U 5 eSn A ff=fN.7f)a<Build 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_imagerNrrrr) rFrMrrcrr#rrr rrwait_for_snapshotid) rOrrrrrr@rCrrrrrs r3create_snapshot"AsyncSandboxClient.create_snapshots< +(!2#  ? EN  "%0M " !ZZ__4+@+@+I-H  % % '))(--/:H ++ KK,    $$  $Q '   sF$C,B0B.8B0 C)C*C.B00C CCC.)context build_argstarget on_build_logrrr@rCc # [X$5upS[R"5RSS3nS[R"5RSS3n[R "US5n[R "US5nS[R"5R3n[R "US5n[R "US 5nUR UU UU UU S 9IShvN IShvN nURU[R"[U 5IShvN U U S 9IShvN URS U-S -U-S-U-S-U-U U S 9IShvN UR[UU UUUUUS9U UUU S9IShvN nURS:wa [SSS9eURUR UUUU U S9IShvN sSSS5IShvN $NNNNNN_N!N!,IShvN (df  g=f7f)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)rr@rrrrCrzrm -rf z && mkdir -p z && tar -xf z -C )remote_contextdockerfile_rel image_ref buildkit_root buildkit_runrr)r@ on_stdout on_stderrrCrz Dockerfile snapshot build failedrr)rrr@rC)ruuiduuid4hex posixpathjoinrwriterq to_threadrrunr exit_codercapture_snapshotr)rOr dockerfilerrrrrrrr@rC context_pathr  builder_name build_rootr  remote_tarr r rrresults r3create_snapshot_from_dockerfile2AsyncSandboxClient.create_snapshot_from_dockerfiles`.(C:'W$ *4::<+;+;CR+@*AB 11A1A#21F0GH " I>^^J > / 0@0@/AB !z?C  ~~j.A / &    --''(@,OO     ++ !!"!!! !    !!    #;;.#1#1'"/!-)! &&'F1$+6",.. &"3 /_   P  (_    sC-H /G0H 8G!9H <+G/'G# ( G/3G%4-G/!G'"'G/ G) ?G/ G+ G/ H G-H !H #G/%G/'G/)G/+G/-H /H5G8 6 HH )rrrr@rCc$# [URUS5nSU0n UbX9S'UbXIS'UbXYS'URRXUR U5S9IShvN n U R 5 [ R"U R55n URU R XgS 9IShvN $NZ![Ra:n U RRS:Xa[S US 3S S 9U e[U 5 eSn A ff=fNW7f)aCapture 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. tag: Tag to publish the snapshot under, within ``name``. Re-using a tag moves it to the new snapshot, leaving the previous one addressable by id. Defaults server-side to ``latest``. 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. rrNrrrrrrrrrr)rrFrMrrcrr#rrr rrrrrrr) rO sandbox_namerrrrr@rCrrrrrs r3r#AsyncSandboxClient.capture_snapshot s(@t~~|Z@#)4. ? EN  #&2N #  (+<' ( !ZZ__4+@+@+I-H  % % '))(--/:H++ KK,    $$ zz%%,+ ~[9 %Q '    sF1D,B= B;!8B=D6D7D;B==D 5DD  Dc# URS[U53nURRX0R U5S9IShvN nUR 5 [ R"UR55$N8![Ra:nURRS:Xa[SUS3SS9Ue[U5 eSnAff=f7f) aoGet a snapshot by ID or by a Docker-style reference. Args: snapshot_id: Snapshot UUID, ``name:tag``, or a bare ``name``. A bare name means ``name:latest``, falling back to the newest ready untagged snapshot of that name. Returns: Snapshot. Raises: ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. /snapshots/rNr Snapshot 'rrr)rFrrMrrcrr#rrr rrrrrrOrrCrrrs r3 get_snapshotAsyncSandboxClient.get_snapshot\s" ,D[,Q+RS !ZZ^^C9N9Nw9W^XXH  % % '%%hmmo6 6Y$$ zz%%,+  [9 %Q '   s:C+B B 7BCBC5C  CCc# URS[U53nURRX0R U5S9IShvN nUR 5 UR 5RS5=(d /Vs/sHn[R"U5PM sn$N`s snf![Ra:nURRS:Xa[SUS3SS 9Ue[U5 eSnAff=f7f) a|List every tag published under a snapshot name. Args: name: Snapshot name, without a tag. Returns: Each tag under the name with the snapshot it resolves to. Empty when the name exists but currently carries no tags. Raises: ResourceNotFoundError: If nobody has published under the name. SandboxClientError: For other errors, including a name carrying a tag. z/snapshots-by-name/rNtagsrzSnapshot name 'rrr)rFrrMrrcrrr$rr rrrrr)rOrrCrrrrs r3list_snapshot_tags%AsyncSandboxClient.list_snapshot_tags{s  34G4M3NO !ZZ^^C9N9Nw9W^XXH  % % '6>mmo6I6I&6Q6WUW6W6Ws %%c*6W Y$$ zz%%,+%dV;7z %Q '   sLD+B1 B* >B1B,'B1)D*B1,B11C?5C::C??D) name_containslimitoffsetrCc,# URS3n0nUbXS'UbX&S'UbX6S'URRUU=(d SURU5S9IShvN nUR 5 UR 5nURS/5V s/sHn [ R"U 5PM sn $NZs sn f![Ra;n U RRS:Xa[S US 35U e[U 5 eSn A ff=f7f) aList snapshots. The backend always paginates this endpoint. When ``limit`` is omitted the server applies a default page size (currently 50), so a single call is not guaranteed to return every snapshot. To iterate through all results, repeat the call with increasing ``offset`` values (or an explicit ``limit``) until fewer than ``limit`` snapshots come back. Args: name_contains: Optional case-insensitive substring filter applied to snapshot names server-side. limit: Optional maximum number of snapshots to return for a single request. Must be between 1 and 500 (inclusive); the server rejects values outside that range. Defaults to 50 server-side when omitted. offset: Optional number of snapshots to skip before returning results. Must be ``>= 0``. Useful for paginating through large result sets in combination with ``limit``. Returns: A single page of Snapshots matching the provided filters. rNr0r1r2)paramsrC snapshotsrrr)rFrMrrcrrr#rr rrrrr) rOr0r1r2rCrr4rrrrs r3list_snapshots!AsyncSandboxClient.list_snapshotss'< +!#  $&3? #  #7O  %8  !ZZ^^~--g6,H  % % '==?D3788K3LM3LaH&&q)3LM MN$$ zz%%,%.se4:; %Q '  sL'D6C B;!8CB=8C:D;C=CD6D  DDcp# URS[U53nURRX0R U5S9IShvN nUR 5 gN![ Ra>nURRS:Xa[SUS3SS9Ue[U5 SnAgSnAff=f7f) zDelete a snapshot. Args: snapshot_id: Snapshot UUID. Raises: ResourceNotFoundError: If snapshot not found. SandboxClientError: For other errors. r'rNrr(rrr) rFrrMrrcrr rrrrrr)s r3delete_snapshot"AsyncSandboxClient.delete_snapshots ,? ,L+MN (!ZZ..227;/H  % % '$$ (zz%%,+  [9 %Q ' '  (s@B6+A! A A!B6A!!B354B.)B6.B33B6i,g@c# SSKnUR5U-nURXS9IShvN nURS:XaU$URS:Xa[ UR =(d SSS9eXeR5- nUS::a[ S US US 3SURS 9e[R"[X855IShvN MNN7f) aPoll 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*rrrrrqrr) rOrr@rrCrrrrs r3r$AsyncSandboxClient.wait_for_snapshots0 >>#g-!..{.LLH')(*+++F/F",!>>#33IA~*  -?yJ", ( --M => > >!L ?s"+CCBCCCC)rGrFrKrMrIrNrH) r? Optional[str]r@floatrAr=rBintrCOptional[Mapping[str, str]]rstr)rr))rCRequestHeadersrzOptional[dict[str, str]])rr)rNone)rr;)r}zOptional[type]r~zOptional[BaseException]rz Optional[Any]rrD)N)rr=rr=rr=rr=r@r?r Optional[int]rrErrErrErrErOptional[SandboxMountConfig]rOptional[SandboxProxyConfig]rCrCrr )rr=rr=rr=rr=r@r?rboolrrErrErrErrErrErrFrrGrCrCrr )rrBrCrCrr )rCrCrzlist[AsyncSandbox]) rrBrr=rrErrErCrCrr )rrBrCrCrrD)rrBrCrCrr") rrBrr?rr?rCrCrr)rrBrrBrrErr=rz$Optional[DownloadContentDisposition]rCrCrr!) rrBr@r?rr>rCrCrr )rrBr@r?rCrCrr )rrBrrBrr?rr=rr=r@r?rCrCrr#)rrBrUnion[str, os.PathLike[str]]rrErrIrr@rr=rzOptional[Callable[[str], Any]]rrErrEr@r?rCrCrr#)r$rBrrBrr=rr=rrEr@r?rCrCrr#)rrBrCrCrr#)rrBrCrCrzlist[SnapshotTag]) r0r=r1rEr2rErCrCrzlist[Snapshot])rrBrCrCrrD) rrBr@r?rr>rCrCrr#)&__name__ __module__ __qualname____firstlineno____doc__rRrXpropertyr^rcrfrirlrwrzrrrrrrrrrrrrrrrr!rr*r.r6r9r__static_attributes__r8r5r3r;r;Ms  '+!%/3(A$(A (A  (A  (A-(AT<<8: = $2 $ )   A&*`#''+"*.37##'+/5959"&`"` ` % `  ``(`$1``!`)`3`3` ` !`H&*D#''+"#*.37##'+/5959"&!D"D D % D  DDD(D$1DD!D)D3D3D  !D" #DN7;%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"%)"&6 6 6  6  6 #6 6  6  6 x,0 \ 1426 $7;##'"&\\1\) \ . \0\\5\\!\\ \ \F"&*+/"&: : :  : $ : ): :  :  : z>B,: @7;%3 F(,# $"& 8%8 8  8  8 8v>B((,:( (<""& +?+? +?  +?  +? +?+?r5r;rA)rr=)ArN __future__rrqosrrcollections.abcrrtypingrrrr langsmithr r/langsmith._openapi_clientr langsmith._openapi_client._httpxr langsmith.sandbox._async_sandboxr langsmith.sandbox._clientrrrrrrrlangsmith.sandbox._exceptionsrrrrrlangsmith.sandbox._helpersrrrrrlangsmith.sandbox._modelsrr r!r"r#r$langsmith.sandbox._mountsr%r&langsmith.sandbox._proxy_configr'langsmith.sandbox._transportr(8langsmith._openapi_client.resources.sandboxes.registriesr)r4r9rBrCr;r8r5r3rasL"  -66'429?< .+ '#s(+,M?M?r5