AXjddlmZddlmZmZmZmZmZddlmZddl m Z ddl m Z ddl Z ddlmZd d lmZmZmZmZmZmZdd lmZmZmZmZmZmZmZmZdd l m!Z!m"Z"m#Z#m$Z$m%Z%d d l&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.ddl/m0Z0m1Z1ddl2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9m:Z:m;Z;ddlZ>d dl?m@Z@mAZAmBZBmCZCmDZDmEZEddlFmGZGddlHmIZIddlJmKZKddlLmMZMddgZNGdde0ZOGdde1ZPGddZQGdd ZRGd!d"ZSGd#d$ZTy)%) annotations)DictListUnionIterableOptional)datetime)chain)LiteralN)_legacy_response)Events AsyncEventsEventsWithRawResponseAsyncEventsWithRawResponseEventsWithStreamingResponse AsyncEventsWithStreamingResponse)BodyOmitQueryHeadersNotGivenSequenceNotStromit not_given)is_given path_templatemaybe_transformstrip_not_givenasync_maybe_transform) ResourcesAsyncResourcesResourcesWithRawResponseAsyncResourcesWithRawResponseResourcesWithStreamingResponse#AsyncResourcesWithStreamingResponse)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncBidirectionalPageCursorAsyncBidirectionalPageCursor)session_list_paramssession_create_paramssession_update_params)AsyncPaginatormake_request_options)Threads AsyncThreadsThreadsWithRawResponseAsyncThreadsWithRawResponseThreadsWithStreamingResponse!AsyncThreadsWithStreamingResponse)AnthropicBetaParam)BetaManagedAgentsSession)BetaManagedAgentsDeletedSession)(BetaManagedAgentsSessionAgentUpdateParamSessions AsyncSessionsceZdZeddZeddZeddZeddZeddZe e e e e ddde d ddZ e ddde d  dd Z e e e e e ddde d dd Z e e e e e e e e e e e e e e ddde d  ddZe ddde d  ddZe ddde d  ddZy)r>c,t|jSN)r_clientselfs p/var/www/html/content_generation/venv/lib/python3.12/site-packages/anthropic/resources/beta/sessions/sessions.pyeventszSessions.events:sdll##c,t|jSrB)r"rCrDs rF resourceszSessions.resources>s&&rHc,t|jSrB)r4rCrDs rFthreadszSessions.threadsBst||$$rHct|Sa This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers )SessionsWithRawResponserDs rFwith_raw_responsezSessions.with_raw_responseFs't,,rHct|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response )SessionsWithStreamingResponserDs rFwith_streaming_responsez Sessions.with_streaming_responsePs-T22rHN metadatarJtitle vault_idsbetas extra_headers extra_query extra_bodytimeoutc .itdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt ||||||dtjt|| | | tS) >Create Session Args: agent: Agent identifier. Accepts the `agent` ID string, which pins the latest version for the session, or an `agent` object with both id and version specified. environment_id: ID of the `environment` defining the container configuration for this session. metadata: Arbitrary key-value metadata attached to the session. Maximum 16 pairs, keys up to 64 chars, values up to 512 chars. resources: Resources (e.g. repositories, files) to mount into the session's container. title: Human-readable session title. vault_ids: Vault IDs for stored credentials the agent can use during the session. betas: Optional header to specify the beta version(s) you want to use. 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 anthropic-beta,c32K|]}t|ywrBstr.0es rF z"Sessions.create..5Lec!femanaged-agents-2026-04-01/v1/sessions?beta=trueagentenvironment_idrVrJrWrXrZr[r\r]bodyoptionscast_to) r rjoinr r_postrr0SessionCreateParamsr3r; rErnrorVrJrWrXrYrZr[r\r]s rFcreatezSessions.createYs\  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz $ "&4 (!*"!* &99 )+Q[el-!  rHrYrZr[r\r]c $|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t S)  Get Session Args: betas: Optional header to specify the beta version(s) you want to use. 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 9Expected a non-empty value for `session_id` but received r`rac32K|]}t|ywrBrcres rFrhz$Sessions.retrieve..rirjrk#/v1/sessions/{session_id}?beta=true session_idrprsrt ValueErrorr rrur r_getrr3r;rErrYrZr[r\r]s rFretrievezSessions.retrieves4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` yy ?J W(+Q[el-   rH rnrVrWrXrYrZr[r\r]c `|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||dtjt||| | t S) Update Session Args: agent: Mid-session agent configuration update. Only `tools` and `mcp_servers` are updatable. Full replacement: the provided array becomes the new value. To preserve existing entries, GET the session, modify the array, and POST it back. metadata: Metadata patch. Set a key to a string to upsert it, or to null to delete it. Omit the field to preserve. title: Human-readable session title. vault_ids: Vault IDs (`vlt_*`) to attach to the session. Not yet supported; requests setting this field are rejected. Reserved for future use. betas: Optional header to specify the beta version(s) you want to use. 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}r`rac32K|]}t|ywrBrcres rFrhz"Sessions.update..rirjrkrrrnrVrWrXrprq) rr rrur rrvrrr1SessionUpdateParamsr3r; rErrnrVrWrXrYrZr[r\r]s rFupdatezSessions.updatesVXYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz ?J W " ("!*  &99)+Q[el-  rHagent_id agent_version created_at_gtcreated_at_gte created_at_ltcreated_at_lte deployment_idinclude_archivedlimitmemory_store_idorderpagestatusesrYrZr[r\r]cTitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t||||||||| | | | | d tjtS)  List Sessions Args: agent_id: Filter sessions created with this agent ID. agent_version: Filter by agent version. Only applies when agent_id is also set. created_at_gt: Return sessions created after this time (exclusive). created_at_gte: Return sessions created at or after this time (inclusive). created_at_lt: Return sessions created before this time (exclusive). created_at_lte: Return sessions created at or before this time (inclusive). deployment_id: Filter sessions created by this deployment ID. include_archived: When true, includes archived sessions. Default: false (exclude archived). limit: Maximum number of results to return. memory_store_id: Filter sessions whose resources contain a memory_store with this memory store ID. order: Sort direction for results, ordered by created_at. Defaults to desc (newest first). page: Opaque pagination cursor from a previous response. statuses: Filter by session status. Repeat the parameter to match any of multiple statuses. betas: Optional header to specify the beta version(s) you want to use. 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`rac32K|]}t|ywrBrcres rFrhz Sessions.list..crirjrkrl rrrrrrrrrrrrrrZr[r\r]queryrrsmodel) r rrur r _get_api_listr-r;r3rr/SessionListParamsrErrrrrrrrrrrrrrYrZr[r\r]s rFlistz Sessions.listsF  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $,-EF(+'%%$,)6)6*8)6*8)6,.rirjrkrrrpr rr rrur r_deleterr3r<rs rFdeletezSessions.deletes4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` || ?J W(+Q[el4   rHc $|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t S)  Archive Session Args: betas: Optional header to specify the beta version(s) you want to use. 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}r`rac32K|]}t|ywrBrcres rFrhz#Sessions.archive..rirjrk+/v1/sessions/{session_id}/archive?beta=truerrpr rr rrur rrvrr3r;rs rFarchivezSessions.archives4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz GT^ _(+Q[el-   rH)returnr)rr")rr4)rrO)rrSrnzsession_create_params.AgentrordrVzDict[str, str] | OmitrJz/Iterable[session_create_params.Resource] | OmitrWOptional[str] | OmitrXSequenceNotStr[str] | OmitrYList[AnthropicBetaParam] | OmitrZHeaders | Noner[ Query | Noner\ Body | Noner]'float | httpx.Timeout | None | NotGivenrr;rrdrYrrZrr[rr\rr]rrr;rrdrnz/BetaManagedAgentsSessionAgentUpdateParam | OmitrVz)Optional[Dict[str, Optional[str]]] | OmitrWrrXrrYrrZrr[rr\rr]rrr;)&r str | Omitr int | OmitrUnion[str, datetime] | Omitrrrrrrrrr bool | OmitrrrrrLiteral['asc', 'desc'] | OmitrrrEList[Literal['rescheduling', 'running', 'idle', 'terminated']] | OmitrYrrZrr[rr\rr]rrz5SyncBidirectionalPageCursor[BetaManagedAgentsSession]rrdrYrrZrr[rr\rr]rrr<__name__ __module__ __qualname__r(rGrJrLrPrTrrryrrrrrrHrFr>r>9s$$''%%--33+/EI&*0415)-$("&;DJ +J  J ( J C J $J .J /J &J "J  J 9J "!J `26)-$("&;D- - / - &- "-  - 9-  "- fBF>B&*0415)-$("&;DG G ? G < G $ G .G /G &G "G  G 9G  "G X $$(596:596:$((, &*/3Z^15)-$("&;D-j j " j 3 j 4 j 3j 4j "j &j j $j -j j Xj /!j &&'j (")j * +j ,9-j . ?/j `26)-$("&;D- - / - &- "-  - 9-  )- f26)-$("&;D- - / - &- "-  - 9-  "- rHceZdZeddZeddZeddZeddZeddZe e e e e ddde d ddZ e ddde d  dd Z e e e e e ddde d dd Z e e e e e e e e e e e e e e ddde d  ddZe ddde d  ddZe ddde d  ddZy)r?c,t|jSrB)rrCrDs rFrGzAsyncSessions.eventss4<<((rHc,t|jSrB)r#rCrDs rFrJzAsyncSessions.resourcessdll++rHc,t|jSrB)r5rCrDs rFrLzAsyncSessions.threadssDLL))rHct|SrN)AsyncSessionsWithRawResponserDs rFrPzAsyncSessions.with_raw_responses,D11rHct|SrR)"AsyncSessionsWithStreamingResponserDs rFrTz%AsyncSessions.with_streaming_responses2$77rHNrUc ^Kitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt ||||||dtjd{t|| | | t d{S7$7w) r_r`rac32K|]}t|ywrBrcres rFrhz'AsyncSessions.create..9rirjrkrlrmNrprq) r rrur rrvr!r0rwr3r;rxs rFryzAsyncSessions.creates\  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ $,"&4 (!*"!* &99  )+Q[el-!      s$BB-B) B-$B+%B-+B-rzc @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) r|r}r`rac32K|]}t|ywrBrcres rFrhz)AsyncSessions.retrieve..srirjrkrrrprNrrs rFrzAsyncSessions.retrieveTs4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` YY ?J W(+Q[el-     BBBBrc K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||dtjd {t||| | t d {S7$7w) rr}r`rac32K|]}t|ywrBrcres rFrhz'AsyncSessions.update..rirjrkrrrNrprq) rr rrur rrvrr!r1rr3r;rs rFrzAsyncSessions.updatesVXYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ ?J W," ("!*  &99)+Q[el-     s$BCC C=C>CCrcTitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt tt||||t||||||||| | | | | d tjtS) rr`rac32K|]}t|ywrBrcres rFrhz%AsyncSessions.list..rirjrkrlrrr) r rrur rrr.r;r3rr/rrs rFrzAsyncSessions.listsF  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $-.FG(+'%%$,)6)6*8)6*8)6,.WrirjrkrrrprNrrs rFrzAsyncSessions.delete8s4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` \\ ?J W(+Q[el4 "    rc @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) rr}r`rac32K|]}t|ywrBrcres rFrhz(AsyncSessions.archive..rirjrkrrrprNrrs rFrzAsyncSessions.archivegs4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ GT^ _(+Q[el-      r)rr)rr#)rr5)rr)rrrrr)&rrrrrrrrrrrrrrrrrrrrrrrrrrrYrrZrr[rr\rr]rrz`AsyncPaginator[BetaManagedAgentsSession, AsyncBidirectionalPageCursor[BetaManagedAgentsSession]]rrrrHrFr?r?s)),,**2288+/EI&*0415)-$("&;DJ +J  J ( J C J $J .J /J &J "J  J 9J "!J `26)-$("&;D- - / - &- "-  - 9-  "- fBF>B&*0415)-$("&;DG G ? G < G $ G .G /G &G "G  G 9G  "G X $$(596:596:$((, &*/3Z^15)-$("&;D-j j " j 3 j 4 j 3j 4j "j &j j $j -j j Xj /!j &&'j (")j * +j ,9-j . j/j `26)-$("&;D- - / - &- "-  - 9-  )- f26)-$("&;D- - / - &- "-  - 9-  "- rHcJeZdZddZeddZeddZed dZy) rOc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrB) _sessionsr to_raw_response_wrapperryrrrrrrEsessionss rF__init__z SessionsWithRawResponse.__init__s!&>> OO  )@@     '>> OO  %<< MM  '>> OO  (??     rHc@t|jjSrB)rrrGrDs rFrGzSessionsWithRawResponse.eventss$T^^%:%:;;rHc@t|jjSrB)r$rrJrDs rFrJz!SessionsWithRawResponse.resourcess'(@(@AArHc@t|jjSrB)r6rrLrDs rFrLzSessionsWithRawResponse.threadss%dnn&<&<==rHNrr>rNone)rr)rr$)rr6rrrrr(rGrJrLrrHrFrOrOsE ,<<BB>>rHrOcJeZdZddZeddZeddZed dZy) rc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrB) rr async_to_raw_response_wrapperryrrrrrrs rFrz%AsyncSessionsWithRawResponse.__init__s!&DD OO  )FF     'DD OO  %BB MM  'DD OO  (EE     rHc@t|jjSrB)rrrGrDs rFrGz#AsyncSessionsWithRawResponse.eventss)$..*?*?@@rHc@t|jjSrB)r%rrJrDs rFrJz&AsyncSessionsWithRawResponse.resourcess,T^^-E-EFFrHc@t|jjSrB)r7rrLrDs rFrLz$AsyncSessionsWithRawResponse.threadss*4>>+A+ABBrHNrr?rr)rr)rr%)rr7rrrHrFrrsI ,AAGGCCrHrcJeZdZddZeddZeddZed dZy) rScJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrB)rr+ryrrrrrrs rFrz&SessionsWithStreamingResponse.__init__s!2 OO  5     3 OO  1 MM  3 OO  4     rHc@t|jjSrB)rrrGrDs rFrGz$SessionsWithStreamingResponse.eventss*4>>+@+@AArHc@t|jjSrB)r&rrJrDs rFrJz'SessionsWithStreamingResponse.resourcess-dnn.F.FGGrHc@t|jjSrB)r8rrLrDs rFrLz%SessionsWithStreamingResponse.threadss+DNN,B,BCCrHNr)rr)rr&)rr8rrrHrFrSrSsI ,BBHHDDrHrScJeZdZddZeddZeddZed dZy) rcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrB)rr,ryrrrrrrs rFrz+AsyncSessionsWithStreamingResponse.__init__s!8 OO  ;     9 OO  7 MM  9 OO  :     rHc@t|jjSrB)rrrGrDs rFrGz)AsyncSessionsWithStreamingResponse.eventss/0E0EFFrHc@t|jjSrB)r'rrJrDs rFrJz,AsyncSessionsWithStreamingResponse.resourcess24>>3K3KLLrHc@t|jjSrB)r9rrLrDs rFrLz*AsyncSessionsWithStreamingResponse.threads"s01G1GHHrHNr)rr)rr')rr9rrrHrFrrsI ,GGMMIIrHr)U __future__rtypingrrrrrr itertoolsr typing_extensionsr httpxr rGrrrrrr_typesrrrrrrrr_utilsrrrr r!rJr"r#r$r%r&r'_compatr( _resourcer)r* _responser+r, paginationr-r. types.betar/r0r1 _base_clientr2r3threads.threadsr4r5r6r7r8r9types.anthropic_beta_paramr:&types.beta.beta_managed_agents_sessionr;.types.beta.beta_managed_agents_deleted_sessionr<9types.beta.beta_managed_agents_session_agent_update_paramr=__all__r>r?rOrrSrrrHrFrs#88% !]\\gg(;ZT B>O^r  'l l ^ l $l ^ !>!>H!C!CH!D!DH!I!IrH