o r)iP@sxddlmZddlmZddlmZddlZddlmZddl m Z m Z ddl m Z mZmZmZmZmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZm Z d dl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddgZ4GdddeZ5GdddeZ6GdddZ7GdddZ8GdddZ9GdddZ:dS) ) annotations)Iterable)LiteralN)_legacy_response)container_list_paramscontainer_create_params) BodyOmitQueryHeadersNoneTypeNotGivenSequenceNotStromit not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)Files AsyncFilesFilesWithRawResponseAsyncFilesWithRawResponseFilesWithStreamingResponseAsyncFilesWithStreamingResponse)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)ContainerListResponse)ContainerCreateResponse)ContainerRetrieveResponse ContainersAsyncContainersc @eZdZed6ddZed7ddZed8d d Zeeeeed d d ed d9d"d#Z d d d ed$d:d'd(Z eeeed d d ed)d;d1d2Z d d d ed$d+container_create_params.ExpiresAfter | Omitr?SequenceNotStr[str] | Omitr@(Literal['1g', '4g', '16g', '64g'] | OmitrA,container_create_params.NetworkPolicy | OmitrB.Iterable[container_create_params.Skill] | OmitrCHeaders | NonerD Query | NonerE Body | NonerF'float | httpx.Timeout | None | NotGivenr%c Cs4|jdt||||||dtjt||| | dtdS) Create Container Args: name: Name of the container to create. expires_after: Container expiration time in seconds relative to the 'anchor' time. file_ids: IDs of files to copy to the container. memory_limit: Optional memory limit for the container. Defaults to "1g". network_policy: Network access policy for the container. skills: An optional list of skills referenced by id or inline data. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds /containersrGr>r?r@rArBrCrDrErFbodyoptionscast_to)_postrrContainerCreateParamsr#r% r/rGr>r?r@rArBrCrDrErFr0r0r1create:s"( zContainers.createrU container_idr&cCs4|s td||jd|t||||dtdS)F Retrieve Container Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds ;Expected a non-empty value for `container_id` but received /containers/rUrXrY ValueError_getr#r&r/r^rCrDrErFr0r0r1retrieveuszContainers.retrieveafterlimitrGorderrCrDrErFri str | Omitrj int | OmitrkLiteral['asc', 'desc'] | Omit%SyncCursorPage[ContainerListResponse]c C6|jdttt||||t||||dtjdtdSaList Containers Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 100, and the default is 20. name: Filter results by container name. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rS)rirjrGrk)rCrDrErFquery)pagerXmodel) _get_api_listr r$r#rrContainerListParams r/rirjrGrkrCrDrErFr0r0r1list&(zContainers.listNonecCsD|s td|ddi|pi}|jd|t||||dtdS)D Delete Container Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds r`Accept*/*rarUrbrd_deleter#r rfr0r0r1deleteszContainers.delete)r*r)r*r4)r*r9rGrHr>rIr?rJr@rKrArLrBrMrCrNrDrOrErPrFrQr*r% r^rHrCrNrDrOrErPrFrQr*r&)rirlrjrmrGrlrkrnrCrNrDrOrErPrFrQr*ro r^rHrCrNrDrOrErPrFrQr*rz __name__ __module__ __qualname__rr2r7r;rrr]rgrxrr0r0r0r1r'"H    A$Cc @r))=r(r*rcCr+r,)rr-r.r0r0r1r2r3zAsyncContainers.filesAsyncContainersWithRawResponsecCr5r6)rr.r0r0r1r7r8z!AsyncContainers.with_raw_response$AsyncContainersWithStreamingResponsecCr5r:)rr.r0r0r1r;r<z'AsyncContainers.with_streaming_responseNr=rGrHr>rIr?rJr@rKrArLrBrMrCrNrDrOrErPrFrQr%c sB|jdt||||||dtjIdHt||| | dtdIdHS)rRrSrTNrUrV)rZrrr[r#r%r\r0r0r1r]s$(  zAsyncContainers.createrUr^r&cs<|s td||jd|t||||dtdIdHS)r_r`rarUrbNrcrfr0r0r1rgIs zAsyncContainers.retrieverhrirlrjrmrkrnMAsyncPaginator[ContainerListResponse, AsyncCursorPage[ContainerListResponse]]c Crprq)rur!r$r#rrrvrwr0r0r1rxjryzAsyncContainers.listrzcsL|s td|ddi|pi}|jd|t||||dtdIdHS)r{r`r|r}rarUrbNr~rfr0r0r1rs zAsyncContainers.delete)r*r)r*r)r*rrr)rirlrjrmrGrlrkrnrCrNrDrOrErPrFrQr*rrrr0r0r0r1r(rc@$eZdZd ddZed dd Zd S) r4 containersr'r*rzcCB||_t|j|_t|j|_t|j|_t|j|_dSr,) _containersrto_raw_response_wrapperr]rgrxrr/rr0r0r1__init__ z"ContainersWithRawResponse.__init__rcC t|jjSr,)rrr2r.r0r0r1r2 zContainersWithRawResponse.filesNrr'r*rz)r*rrrrrrr2r0r0r0r1r4 r4c@r) rrr(r*rzcCrr,)rrasync_to_raw_response_wrapperr]rgrxrrr0r0r1rrz'AsyncContainersWithRawResponse.__init__rcCrr,)rrr2r.r0r0r1r2rz$AsyncContainersWithRawResponse.filesNrr(r*rz)r*rrr0r0r0r1rrrc@r) r9rr'r*rzcC:||_t|j|_t|j|_t|j|_t|j|_dSr,)rrr]rgrxrrr0r0r1r z(ContainersWithStreamingResponse.__init__rcCrr,)rrr2r.r0r0r1r2rz%ContainersWithStreamingResponse.filesNr)r*rrr0r0r0r1r9rr9c@r) rrr(r*rzcCrr,)rrr]rgrxrrr0r0r1r rz-AsyncContainersWithStreamingResponse.__init__rcCrr,)rrr2r.r0r0r1r2rz*AsyncContainersWithStreamingResponse.filesNr)r*rrr0r0r0r1r rr); __future__rtypingrtyping_extensionsrhttpxrtypesrr_typesr r r r r rrrr_utilsrr_compatr _resourcerr _responserr files.filesrrrrrr paginationr r! _base_clientr"r#types.container_list_responser$types.container_create_responser%!types.container_retrieve_responser&__all__r'r(r4rr9rr0r0r0r1s4    ,     UU