o ;i#@sUddlZddlZddlZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z ddlmZmZmZmZmZmZmZddlmZddlmZmZerUddlZdd lmZdd lmZdd lm Z m!Z!dd l"m#Z#dd l$m%Z%ddl&m'Z'm(Z)ddl*m+Z+ddl,m-Z-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4m5Z5ddl6m7Z7ddl8m9Z9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDmEZEmFZFmGZGddlHmIZImJZJmKZKddlLmMZMddlNmOZOddlPmQZQmRZRmSZSmTZTddlUmVZVmWZWdd lXmYZYdd!lZm[Z[dd"l\m]Z]dd#l^m_Z_eO`ZaeOebd$<d%Zcd&Zder&ddleZfd'e egd(dfd)d*ZhGd+d,d,egZieiZje d-d.Gd/d0d0ZkGd1d2d2e.d3d4Zle5elZmdS)5N)AsyncGenerator CollectionSequence) dataclass) PurePosixPath) TYPE_CHECKINGAny AsyncIteratorLiteralOptionalUnionoverload get_pty_info)configlogger)Message)Tunnel)_CloudBucketMountcloud_bucket_mounts_to_proto)_Mount)_Volume)api_pb2task_command_router_pb2) LoadContext)_get_environment_name_Object)Resolver)%convert_fn_config_to_resources_config) TaskContextsynchronize_api)deprecation_warning)validate_network_file_systemsvalidate_volumes)check_object_name)TaskCommandRouterClient)_Client)_ContainerProcess)ExecutionError InvalidErrorSandboxTerminatedErrorSandboxTimeoutError)FileWatchEventFileWatchEventType_FileIO)GPU_T)_Image) StreamReader StreamWriter _StreamReader _StreamWriter)_NetworkFileSystem network_file_system_mount_protos)_Proxy)_Secret)_SandboxSnapshot) StreamType_default_imageiargsreturncCsNtdd|Ds tdtdd|D}|tkr%tdtd|ddS)Ncss|]}t|tVqdSN) isinstancestr.0argrFA/home/ubuntu/.local/lib/python3.10/site-packages/modal/sandbox.py Hsz&_validate_exec_args..z(All entrypoint arguments must be stringscss|]}t|VqdSr@)lenrCrFrFrGrHKsz,Total length of CMD arguments cannot exceed z bytes (ARG_MAX). Got z bytes.)allr*sum ARG_MAX_BYTES)r> total_arg_lenrFrFrG_validate_exec_argsFsrNc@seZdZdZdefddZdS)DefaultSandboxNameOverridezA singleton class that represents the default sandbox name override. It is used to indicate that the sandbox name should not be overridden. r?cCsdS)N_DEFAULT_SANDBOX_NAME_OVERRIDErFselfrFrFrG__repr__Xsz#DefaultSandboxNameOverride.__repr__N)__name__ __module__ __qualname____doc__rBrSrFrFrFrGrORsrOT)frozenc@s"eZdZUdZeed<eed<dS)SandboxConnectCredentialszSSimple data structure storing credentials for making HTTP connections to a sandbox.urltokenN)rTrUrVrWrB__annotations__rFrFrFrGrY`s  rYc@@sn eZdZUdZeejed<ee ed<ee ed<e ed<ee ed<ee e e fed<eed<eeed <ed ejfd d Zed dd d d d d d d didd idd gggd d ddd fdee dedeedee de dee dee dedee deee ee fdeedeee ee e ffdeede ee ejfefded eee d!e ee ejfeee ffd"ed#eejd$ee d%ee d&ee d'ee!d(ee e efd)ed*ed+ee d df8d,d-Z"ed d d d d idd d d d d d d dd idgggd d dd dd d d d.de d/ed0dee deed1ee e ee fdeeede ee ejfefde dee dee dedee deee ee fdeeeeeeffdeee ee e ffded eee d!e ee ejfeee ffd"ed$ee d%ee d&ee d+ee d'ee!d*ed(ee e efd2ed3ee#d4ee d#eejd df>d5d6Z$ed d d d d didd d d d d d d dd idgggd d dd dd d d7de d/ed0dee deed1ee e ee fdeeedeede ee ejfefde dee dee dedee deee ee fdeeeeeeffdeee ee e ffded eee d!e ee ejfeee ffd"ed$ee d%ee d&ee d'ee!d(ee e efd2ed3ee#d*ed#eejd+ee fe de d4ee d3ee#d df d?d@Z(eddAe d3ee#d dfdBdCZ)d e e e ffdDdEZ*d dFdGe e e fd3ee#d d fdHdIZ+dde d efdKdLZ,dMee-e fdeefdNdOZ.dMee-e fd efdPdQZ/ddSefdTdUZ0dde d e e e ffdWdXZ1 ddYeee e e e2ffd e3fdZd[Z4dd\d]Z5dd^d_Z6d ee fd`daZ7d e fdbdcZ8dde d eefdedfZ9e:e;je fdodpZ?e:e;je@fdqdpZ?e;je@e>e ffdudvZAd e;je@e>e ffdzd{ZBd e;je@e>e ffd}d~ZCd eDfddZEe deFddeDd3ee#dee fddZGe:dMe ddd eHe fddZIe:dMe ddd eHe@fddZI ddMe dedfddZIdMe d eJjKe fddZLddMe ded d fddZMddMe ded d fddZN ddMe deeJjKeOdeedee d ePeQf ddZReSd ee fddZTeSd ee fddZUeSd e fddZVeSd ee fddZWed d d ddee dGee e e fd3ee#d eXdfddZKd S)_Sandboxa<A `Sandbox` object lets you interact with a running sandbox. This API is similar to Python's [asyncio.subprocess.Process](https://docs.python.org/3/library/asyncio-subprocess.html#asyncio.subprocess.Process). Refer to the [guide](https://modal.com/docs/guide/sandbox) on how to spawn and use sandboxes. _result_stdout_stderr_stdin_task_id_tunnels_enable_snapshot_command_router_clientr?cCs tdddS)NT)shellno_terminate_on_idle_stdinrrFrFrFrG_default_pty_infoxs z_Sandbox._default_pty_infoNi,rFFr>imagesecretsnametimeout idle_timeoutworkdirgpucloudregioncpumemorymountsnetwork_file_systems block_networkcidr_allowlistvolumesptypty_infoencrypted_portsh2_portsunencrypted_portsproxyexperimental_optionsenable_snapshotverbose custom_domaincs,t| t tr tddurdstdt|ddDddDd| rIt| tr;| gn| rAt| nd}tj|d|rOt d tt f fd d }d t d t dt dttf fdd }t j|d|t dS)z mdmd:hiddenzhSandboxes do not support configuring a list of GPUs. Specify a single GPU configuration, e.g. gpu='a10g'N/'workdir must be an absolute path, got: cS"g|] \}}t|tr||fqSrF)rArrDkvrFrFrG "z!_Sandbox._new..cSrrF)rArrrFrFrGrr)regionsr?csxgtt}D] \}}||q D] \}}||qD] \}}|jr2||jq%r:||Sr@)listappendsecret)deps_volcloud_bucket_mount)cloud_bucket_mountsrirtr~rjvalidated_network_file_systemsvalidated_volumesrFrG_depss       z_Sandbox._new.._depsrRresolver load_context_existing_object_idc sJddD}ddD}|ddD|dd Dr7dur-tdtjtjjjd}ndurEtjtjjjd}n tjtjjjd}d}tjd)id d j d d dDd d j Dd ddDdd ddt  |ddrnddt dt ddt ddtd|dddt ddtj|d d!|d"rˆj n2dd#d$d%d& d'}tj|j|d(} |jj| IdH} | j} || |jddSd#d$d%d& d'}tj|j|d(} |jj| IdH} | j} || |jddS)*NcSs&g|]\}}tj||jd|jdqS)T) mount_path volume_idallow_background_commits read_only)r VolumeMount object_id _read_only)rDpathvolumerFrFrGrsz0_Sandbox._new.._load..cSg|] }tj|ddqS)Fport unencryptedrPortSpecrDrrFrFrGrcSr)TrrrrFrFrGrrcSsg|] }tj|dtjdqS)F)rr tunnel_type)rrTUNNEL_TYPE_H2rrFrFrGrsz?`cidr_allowlist` cannot be used when `block_network` is enabled)network_access_type)r allowed_cidrsentrypoint_argsimage_id mount_idscSg|]}|jqSrFr)rDmountrFrFrGr secret_idscSrrFrrDrrFrFrGrr timeout_secsidle_timeout_secsrn resources)rrrsroephemeral_diskcloud_provider_str nfs_mountsruntimefunction_runtime runtime_debugfunction_runtime_debugr volume_mountsrzscheduler_placement worker_id open_ports)portsnetwork_accessproxy_idrrrkrr)app_id definitionrF)extendr*r NetworkAccessNetworkAccessTypeBLOCKEDOPEN ALLOWLISTSandboxr _mount_layersrr7rgetr PortSpecsSandboxCreateRequestrclientstub SandboxCreate sandbox_id_hydrate) rRrrrrrrrr create_req create_resprr>rvrwrprrrrrr{rror|rmrirsrtrkr~rzrrjrlr}rrrrnrFrG_loads        z_Sandbox._new.._loadz Sandbox())rload_context_overrides)r#rArr* startswithr$rBrSchedulerPlacementr]rhrrrr _from_loaderempty)r>rirjrkrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrrrrrrFrrG_new|s6   " BMz _Sandbox._new)apprkrienvrjrurlrmrnrorprqrrrsrvrwrxryr{r|r}rr~rr_experimental_enable_snapshotrenvironment_namerzrzmodal.app._Apprrrrcs|dur tdd|durtdd|pg}|r"g|t|}tj|id|d|d|d |d |d |d |d |d| d| d| d| d| d|d|d|d|d|d|d|d|d|d|d|d|d|d |IdHS)!a Create a new Sandbox to run untrusted, arbitrary code. The Sandbox's corresponding container will be created asynchronously. **Usage** ```python app = modal.App.lookup('sandbox-hello-world', create_if_missing=True) sandbox = modal.Sandbox.create("echo", "hello world", app=app) print(sandbox.stdout.read()) sandbox.wait() ``` N)zPassing `environment_name` to `Sandbox.create` is deprecated and will be removed in a future release. A sandbox's environment is determined by the app it is associated with.r zzThe `pty_info` parameter is deprecated and will be removed in a future release. Set the `pty` parameter to `True` instead.rrkrirjrurlrmrnrorprqrrrsrvrwrxryr{r|r}r~rrrrrzr)r"r9 from_dictr]_create)rrkrirrjrurlrmrnrorprqrrrsrvrwrxryr{r|r}rr~rrrrrrzr>rFrFrGcreates@      z_Sandbox.create)rrkrirrjrtrurlrmrnrorprqrrrsrvrwrxryr{r|r}r~rrrrrzrc& sddlm}t||durt|d|r |s|s|r td|p#g}|r/g|t|}tj|fid|p8t d|d|d |d |d | d | d | d| d| d|d|d|d|d|d|d|d|d|d|d|d|d|d|d|d|}||_ d} d}!|dur|j durt d |j } |j }!n|}"dur|"j } |"j }!ntd!|p|!}t}#t4IdH}$t|| |$d"}%|#||%IdHWdIdH|S1IdHswY|S)#a#Private method used internally. This method exposes some internal arguments (currently `mounts`) which are not in the public API. `mounts` is currently only used by modal shell (cli) to provide a function's mounts to the sandbox that runs the shell session. r)_AppNrz9Cannot specify open ports when `block_network` is enabledrirjrkrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrraApp has not been initialized yet. To create an App lazily, use `App.lookup`: app = modal.App.lookup('my-app', create_if_missing=True) modal.Sandbox.create('echo', 'hi', app=app) In order to initialize an existing `App` object, refer to our docs: https://modal.com/docs/guide/appsaSandboxes require an App when created outside of a Modal container. Run an ephemeral App (`with app.run(): ...`), or reference a deployed App using `App.lookup`: ``` app = modal.App.lookup("sandbox-app", create_if_missing=True) sb = modal.Sandbox.create(..., app=app) ```)rr task_context)rrrNr%r*r9rr]rr<rdr ValueError_client_get_container_apprr rload)&rrkrirrjrtrurlrmrnrorprqrrrsrvrwrxryr{r|r}r~rrrrrzrr>robjr app_client container_apprtcrrFrFrGrs '        z_Sandbox._createhandle_metadatacCshttj|jd|jdd|_ttj|jd|jdd|_t|jd|j|_ d|_ d|_ d|_ d|_ d|_dS)NsandboxT)by_lineF)r2rFILE_DESCRIPTOR_STDOUTrrr_FILE_DESCRIPTOR_STDERRr`r3rar^rbrcrdre)rRrrFrFrG_hydrate_metadatas z_Sandbox._hydrate_metadata)rrapp_namecsR|dur tIdH}t|}tj|||d}|j|IdH}t|j |dS)zGet a running Sandbox by name from a deployed App. Raises a modal.exception.NotFoundError if no running sandbox is found with the given name. A Sandbox's name is the `name` argument passed to `Sandbox.create`. N) sandbox_namerr) r'from_envrrSandboxGetFromNameRequestrSandboxGetFromNamer] _new_hydratedr)rrkrrenv_namereqresprFrFrG from_names z_Sandbox.from_namercsZ|dur tIdH}tj|dd}|j|IdH}t||d}|jj r+|j|_ |S)zConstruct a Sandbox from an id and look up the Sandbox result. The ID of a Sandbox object can be accessed using `.object_id`. Nrrrl) r'rrSandboxWaitRequestr SandboxWaitr]rresultstatusr^)rrr r rrFrFrGfrom_idsz_Sandbox.from_idcs4tj|jd}|jj|IdH}dd|jDS)zVFetches any tags (key-value pairs) currently attached to this Sandbox from the server.rNcSsi|]}|j|jqSrFtag_name tag_value)rDtagrFrFrG 4sz%_Sandbox.get_tags..)rSandboxTagsGetRequestrrrSandboxTagsGettagsrRr r rFrFrGget_tags/sz_Sandbox.get_tagsrrcsVt}|dur tdddd|D}tj||j|d}|jj|IdHdS)z`Set tags (key-value pairs) on the Sandbox. Tags can be used to filter results in `Sandbox.list`.N)rrzThe `client` parameter is deprecated. Set `client` when creating the Sandbox instead (in e.g. `Sandbox.create()`/`.from_id()`/`.from_name()`).cSg|] \}}tj||dqSrr SandboxTagrDrkvaluerFrFrGr@z%_Sandbox.set_tags..)rrr) rr"itemsrSandboxTagsSetRequestrrrSandboxTagsSet)rRrrr tags_listr rFrFrGset_tags6sz_Sandbox.set_tags7c s|IdHtj|j|d}|jj|IdH}|jjtj j kr(t |jj |j }|j}dtdtdtdttfdd}d }tj||d td }|||j||S) zSnapshot the filesystem of the Sandbox. Returns an [`Image`](https://modal.com/docs/reference/modal.Image) object which can be used to spawn a new Sandbox with the same filesystem. Nr rRrrexisting_object_idcdSr@rFrRrrr,rFrFrGrYsz+_Sandbox.snapshot_filesystem.._loadzImage()Thydrate_lazilyr) _get_task_idrSandboxSnapshotFsRequestrrrSandboxSnapshotFsrr GenericResultGENERIC_STATUS_SUCCESSr) exceptionrimage_metadatar1rrr rBrrr) rRrlr r rmetadatarreprirFrFrGsnapshot_filesystemIs z_Sandbox.snapshot_filesystemrc sd}|r|js td|j}nd}|IdH}||IdH}dur)tdt|}|s8td||d}tj |||d}| |IdHdS)z3Mount an Image at a path in the Sandbox filesystem.NzImage has not been built.zTMounting directories requires direct Sandbox control - please contact Modal support.z"Mount path must be absolute; got: utf8)task_idrr) _object_idr*r1_get_command_router_clientr is_absoluteas_posixencodesr_pb2TaskMountDirectoryRequest mount_image) rRrrirr=command_router_client posix_path path_bytesr rFrFrG_experimental_mount_imageds z"_Sandbox._experimental_mount_imagecs|IdH}||IdH}durtdt|}|s'td||d}tj||d}| |IdH}t |j |j dS)zKSnapshot local changes to a previously mounted Image, creating a new Image.NzXSnapshotting directories requires direct Sandbox control - please contact Modal support.z%Snapshot path must be absolute; got: r<)r=r)r1r?r*rr@rArBrCTaskSnapshotDirectoryRequestsnapshot_directoryr1rrr)rRrr=rFrGrHr resrFrFrG _experimental_snapshot_directory}sz)_Sandbox._experimental_snapshot_directoryTraise_on_terminationcs tj|jdd}|jj|IdH}|jjrDt d|jd|jj|j|_ |jjtj j kr5t |jjtj jkrB|rBtdSq)z'Wait for the Sandbox to finish running.T r NzSandbox z wait completed with status )rr rrrrrrrdebugr^r4GENERIC_STATUS_TIMEOUTr,GENERIC_STATUS_TERMINATEDr+)rRrNr r rFrFrGwaitsz _Sandbox.wait2cs`|jr|jStj|j|d}|jj|IdH}|jjtj j kr$t dd|j D|_|jS)aGet Tunnel metadata for the sandbox. Raises `SandboxTimeoutError` if the tunnels are not available after the timeout. Returns a dictionary of `Tunnel` objects which are keyed by the container port. NOTE: Previous to client [v0.64.153](https://modal.com/docs/reference/changelog#064153-2024-09-30), this returned a list of `TunnelData` objects. r NcSs&i|]}|jt|j|j|j|jqSrF)container_portrhostrunencrypted_hostunencrypted_port)rDtrFrFrGrsz$_Sandbox.tunnels..) rcrSandboxGetTunnelsRequestrrrSandboxGetTunnelsrrr4rQr,tunnels)rRrlr r rFrFrGr\s z_Sandbox.tunnels user_metadatac s||dur%t|tr%zt|}Wnty$}ztd|d}~wwtj|j|d}|j j |IdH}t |j |jS)a [Alpha] Create a token for making HTTP connections to the Sandbox. Also accepts an optional user_metadata string or dict to associate with the token. This metadata will be added to the headers by the proxy when forwarding requests to the Sandbox.Nz#Failed to serialize user_metadata: )rr])rAdictjsondumps Exceptionr*r SandboxCreateConnectTokenRequestrrrSandboxCreateConnectTokenrYrZr[)rRr]er r rFrFrGcreate_connect_tokensz_Sandbox.create_connect_tokencs0|IdH}|jjtj|dIdHdS)zMReload all Volumes mounted in the Sandbox. Added in v1.1.0. N)r=)r1rrContainerReloadVolumesrContainerReloadVolumesRequestrRr=rFrFrGreload_volumessz_Sandbox.reload_volumescs$|jjtj|jdIdHdS)zbTerminate Sandbox execution. This is a no-op if the Sandbox has already finished running.rN)rrSandboxTerminaterSandboxTerminateRequestrrQrFrFrG terminates"z_Sandbox.terminatecs<tj|jdd}|jj|IdH}|jjr|j|_|j S)zCheck if the Sandbox has finished running. Returns `None` if the Sandbox is still running, else returns the exit code. rr N) rr rrrrrrr^ returncoderrFrFrGpolls z _Sandbox.pollcsP|js%|jjtj|jdIdH}|j|_|js"t dIdH|jr|jS)Nrg?) rbrrSandboxGetTaskIdrSandboxGetTaskIdRequestrr=asynciosleep)rRr rFrFrGr1sz_Sandbox._get_task_idr=cs(|jdurt|j|IdH|_|jSr@)rer&try_initrrhrFrFrGr?s z#_Sandbox._get_command_router_client) stdoutstderrrlrnrrjtextbufsizeryrz _pty_inforurvrwrx)rtrryc r-r@rF rRrurvrlrnrrjrwrxryrzryr>rFrFrGexecz _Sandbox.execc r-r@rFrzrFrFrGr{r|) rurvrlrnrrjrwrxryryrzc sV| dus | durtdd| p| } | r|} |j| | ||||||||d IdHS)aExecute a command in the Sandbox and return a ContainerProcess handle. See the [`ContainerProcess`](https://modal.com/docs/reference/modal.container_process#modalcontainer_processcontainerprocess) docs for more information. **Usage** ```python fixture:sandbox process = sandbox.exec("bash", "-c", "for i in $(seq 1 3); do echo foo $i; sleep 0.1; done") for line in process.stdout: print(line) ``` NrzThe `_pty_info` and `pty_info` parameters are deprecated and will be removed in a future release. Set the `pty` parameter to `True` instead. rzrurvrlrnrrjrwrx)r"rh_exec) rRrurvrlrnrrjrwrxryryrzr>rFrFrGr{!s*!r}c  s|dur|dstd|t| |pg}|r$g|t|}fdd|D} tj| IdHIdH} | |||||dd|D|| t dd } | IdH}durl|| d <j | i| IdHSj | i| IdHS) zPrivate method used internally. This method exposes some internal arguments (currently `pty_info`) which are not in the public API. Nrrcsg|] }|jjdqS)r)hydraterrrQrFrGrsrz"_Sandbox._exec..cSrrFrrrFrFrGr~rr) r=rzrurvrlrnrrwrxrrF) rr*rNr9rr gatherr1rrr?_exec_through_command_router_exec_through_server)rRrzrurvrlrnrrjrwrxr> secret_corosr=kwargsrFrFrQrGr~Ys2 z_Sandbox._exec) rzrurvrlrnrrwrxrrrc  stj|| || |p d||d} |jj| IdH} | dk}|r)tt|tnd}t d| j d|j t | j ||j|||||dS)z+Execute a command through the Modal server.r)r=commandrzrrrnrNrz%Created ContainerProcess for exec_id z on Sandbox )rurvrw exec_deadliner)rContainerExecRequestrr ContainerExectime monotonicintCONTAINER_EXEC_TIMEOUT_BUFFERrrPexec_idrr()rRr=rzrurvrlrnrrwrxrr>r r rrrFrFrGrs0 z_Sandbox._exec_through_serverrFc  stt} |tjkrtjj}n|tjkrtjj }n|tj kr%tjj}nt d|tjkr3tj j }n|tjkr=tj j}n|tj krGtj j }nt dtj|| | ||||||| d }||IdH}t| ||j|||| | dk|rztt|d Sdd S)zLExecute a command through a task command router running on the Modal worker.z!Unsupported StreamType for stdoutz!Unsupported StreamType for stderr) r=r command_args stdout_config stderr_configrrnrrzrNr)rFrurvrwrr)rBuuiduuid4r;PIPErCTaskExecStdoutConfigTASK_EXEC_STDOUT_CONFIG_PIPEDEVNULLTASK_EXEC_STDOUT_CONFIG_DEVNULLSTDOUTrTaskExecStderrConfigTASK_EXEC_STDERR_CONFIG_PIPETASK_EXEC_STDERR_CONFIG_DEVNULLTaskExecStartRequest exec_startr(rrrr)rRr=rFrzrurvrlrnrrwrxrr> process_idrr start_reqrrFrFrGrsT               z%_Sandbox._exec_through_command_routerc s|IdHtj|jd}|jj|IdH}|j}tj|dd}|jj |IdH}|j j tj j kr;t|j jdtdtdtdttfdd }d }tj||d td }|||jd|S) NrK@) snapshot_idrlrRrrr,cr-r@rFr.rFrFrGrsz._Sandbox._experimental_snapshot.._loadzSandboxSnapshot()Tr/)r1rSandboxSnapshotRequestrrrSandboxSnapshotrSandboxSnapshotWaitRequestSandboxSnapshotWaitrrr4r5r)r6r:rrr rBrrr) rRsnap_req snap_resprwait_req wait_resprr9rrFrFrG_experimental_snapshots,  z_Sandbox._experimental_snapshot)rksnapshotcs|p tIdH}|dur|tkrt|d|tur&tj|jtjjd}n|dur5tj|jtjjd}n tj|j|tjj d}|j |IdH}t |j|IdH}tj|jddd}|j |IdH}|jjtjjtjjfvrwt|jj|S)Nr)rsandbox_name_override_type)rsandbox_name_overriderTr)rwait_until_readyrl)r'rrPr%rSandboxRestoreRequestr&SANDBOX_NAME_OVERRIDE_TYPE_UNSPECIFIEDSANDBOX_NAME_OVERRIDE_TYPE_NONE!SANDBOX_NAME_OVERRIDE_TYPE_STRINGrSandboxRestorer]rrrpro task_resultrr4GENERIC_STATUS_UNSPECIFIEDr5r)r6)rrrk restore_req restore_respr task_id_reqr rFrFrG_experimental_from_snapshots>  z$_Sandbox._experimental_from_snapshotmode_typeshed.OpenTextModecr-r@rFrRrrrFrFrGopen:z _Sandbox.open_typeshed.OpenBinaryModecr-r@rFrrFrFrGrArr)rrcs(|IdH}t|||j|IdHS)ay[Alpha] Open a file in the Sandbox and return a FileIO handle. See the [`FileIO`](https://modal.com/docs/reference/modal.file_io#modalfile_iofileio) docs for more information. **Usage** ```python notest sb = modal.Sandbox.create(app=sb_app) f = sb.open("/test.txt", "w") f.write("hello") f.close() ``` N)r1r/rr)rRrrr=rFrFrGrHscs&|IdH}t||j|IdHS)z8[Alpha] List the contents of a directory in the Sandbox.N)r1r/lsr)rRrr=rFrFrGr]sz _Sandbox.lsparentsc(|IdH}t||j||IdHS)z.[Alpha] Create a new directory in the Sandbox.N)r1r/mkdirr)rRrrr=rFrFrGrbz_Sandbox.mkdir recursivecr)z2[Alpha] Remove a file or directory in the Sandbox.N)r1r/rmr)rRrrr=rFrFrGrgrz _Sandbox.rmfiltercCs@|IdH}t||j||||2z 3dHW}|Vq6dS)z=[Alpha] Watch a file or directory in the Sandbox for changes.N)r1r/watchr)rRrrrrlr=eventrFrFrGrls "z_Sandbox.watchcC|jS)z [`StreamReader`](https://modal.com/docs/reference/modal.io_streams#modalio_streamsstreamreader) for the sandbox's stdout stream. )r_rQrFrFrGruxz_Sandbox.stdoutcCr)z[`StreamReader`](https://modal.com/docs/reference/modal.io_streams#modalio_streamsstreamreader) for the Sandbox's stderr stream. )r`rQrFrFrGrvsz_Sandbox.stderrcCr)z [`StreamWriter`](https://modal.com/docs/reference/modal.io_streams#modalio_streamsstreamwriter) for the Sandbox's stdin stream. )rarQrFrFrGstdinrz_Sandbox.stdincCsN|jdus |jjtjjkrdS|jjtjjkrdS|jjtjjkr#dS|jjS)zKReturn code of the Sandbox process if it has finished running, else `None`.N|)r^rrr4rrQrRexitcoderQrFrFrGrmsz_Sandbox.returncode)rrrr)r]Nc Csd}t}|durtIdH}|rdd|Dng} tj|||d|d}|j|IdH}|js7dS|jD]}t |j |d} |j j | _| Vq:|jdj}q)zList all Sandboxes for the current Environment or App ID (if specified). If tags are specified, only Sandboxes that have at least those tags are returned. Returns an iterator over `Sandbox` objects.NcSrr r!r#rFrFrGrr%z!_Sandbox.list..TF)rbefore_timestamprinclude_finishedrrt)rr'rr&rSandboxListRequestr SandboxList sandboxesr]rid task_inforr^ created_at) rrrrrr)r r  sandbox_inforrFrFrGrs.    z _Sandbox.listr@)r+)T)rT)r?N)r)F)NNN)YrTrUrVrWr rr4r\r4rBr5r^rrboolr& staticmethodPTYInforhrr1rr9r0r floattuplerosPathLiker6rrr8rr'rrrrr rrr*r:rrIrMrSr\rrYrerirlrnr1r?r r;rr r(r{bytesr~rrr:rrPrr/rbuiltinsrrrrr.r r-rpropertyrurvrrmrrFrFrFrGr]hs                  !#%')*,-./0 p        w (                  ;    6     ,      B *       r]sb) type_prefix)nrqrr_rrrcollections.abcrrr dataclassesrpathlibrtypingrrr r r r r _output.ptyrrr _typeshedgoogle.protobuf.messager modal._tunnelrmodal.cloud_bucket_mountrr modal.mountr modal.volumer modal_protorrrC _load_contextr_objectrr _resolverr _resourcesr_utils.async_utilsr r!_utils.deprecationr"_utils.mount_utilsr#r$_utils.name_utilsr%!_utils.task_command_router_clientr&rr'container_processr(r6r)r*r+r,file_ior-r.r/ror0rir1 io_streamsr2r3r4r5network_file_systemr6r7r~r8rr9rr: stream_typer; debian_slimr<r\rLr modal.appmodalrBrNrOrPrYr]rrFrFrFrGsz   $                       g