jޞddlmZddlmZmZmZmZmZddlmZddl 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@mAZAmBZBmCZCmDZDmEZEddlFmGZGddlHmIZIddlJmKZKddgZLGdde0ZMGdde1ZNGddZOGddZPGd d!ZQGd"d#ZRy)$) 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)SyncPageCursorAsyncPageCursor)session_list_paramssession_create_paramssession_update_params)AsyncPaginatormake_request_options)Threads AsyncThreadsThreadsWithRawResponseAsyncThreadsWithRawResponseThreadsWithStreamingResponse!AsyncThreadsWithStreamingResponse)AnthropicBetaParam)BetaManagedAgentsSession)BetaManagedAgentsDeletedSessionSessions AsyncSessionsceZdZeddZeddZeddZeddZeddZe e e e e ddde d ddZ e ddde d  dd Z e e e e ddde d  dd Z 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 ]/var/www/html/venv/lib/python3.12/site-packages/anthropic/resources/beta/sessions/sessions.pyeventszSessions.events5sdll##c,t|jSrA)r"rBrCs rE resourceszSessions.resources9s&&rGc,t|jSrA)r4rBrCs rEthreadszSessions.threads=st||$$rGct|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 )SessionsWithRawResponserCs rEwith_raw_responsezSessions.with_raw_responseAs't,,rGct|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 )SessionsWithStreamingResponserCs rEwith_streaming_responsez Sessions.with_streaming_responseKs-T22rGN metadatarItitle 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|ywrAstr.0es rE z"Sessions.create..5Lec!femanaged-agents-2026-04-01/v1/sessions?beta=trueagentenvironment_idrUrIrVrWrYrZr[r\bodyoptionscast_to) r rjoinr r_postrr0SessionCreateParamsr3r; rDrmrnrUrIrVrWrXrYrZr[r\s rEcreatezSessions.createTs\  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz $ "&4 (!*"!* &99 )+Q[el-!  rGrXrYrZr[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_r`c32K|]}t|ywrArbrds rErgz$Sessions.retrieve..rhrirj#/v1/sessions/{session_id}?beta=true session_idrorrrs ValueErrorr rrtr r_getrr3r;rDrrXrYrZr[r\s rEretrievezSessions.retrieves4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` yy ?J W(+Q[el-   rGrUrVrWrXrYrZr[r\c ^|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t|||dtjt|||| t S) Update Session Args: 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_r`c32K|]}t|ywrArbrds rErgz"Sessions.update..rhrirjr~rrUrVrWrorp) rr rrtr rrurrr1SessionUpdateParamsr3r; rDrrUrVrWrXrYrZr[r\s rEupdatezSessions.updatesLXYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz ?J W ("!* &99 )+Q[el-  rGagent_id agent_version created_at_gtcreated_at_gte created_at_ltcreated_at_lteinclude_archivedlimitmemory_store_idorderpagestatusesrXrYrZr[r\cRitdt| 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). 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's next_page. 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_r`c32K|]}t|ywrArbrds rErgz Sessions.list..Urhrirjrk rrrrrrrrrrrrrYrZr[r\queryrrrmodel) r rrtr r _get_api_listr-r;r3rr/SessionListParamsrDrrrrrrrrrrrrrXrYrZr[r\s rElistz Sessions.lists@  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $ 89(+'%%$,)6)6*8)6*8,.rhrirjr~rror rr rrtr r_deleterr3r<rs rEdeletezSessions.deletezs4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` || ?J W(+Q[el4   rGc $|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_r`c32K|]}t|ywrArbrds rErgz#Sessions.archive..rhrirj+/v1/sessions/{session_id}/archive?beta=truerror rr rrtr rrurr3r;rs rEarchivezSessions.archives4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz GT^ _(+Q[el-   rG)returnr)rr")rr4)rrN)rrRrmzsession_create_params.AgentrnrcrUzDict[str, str] | OmitrIz/Iterable[session_create_params.Resource] | OmitrVOptional[str] | OmitrWSequenceNotStr[str] | OmitrXList[AnthropicBetaParam] | OmitrYHeaders | NonerZ Query | Noner[ Body | Noner\'float | httpx.Timeout | None | NotGivenrr;rrcrXrrYrrZrr[rr\rrr;rrcrUz)Optional[Dict[str, Optional[str]]] | OmitrVrrWrrXrrYrrZrr[rr\rrr;)$r str | Omitr int | OmitrUnion[str, datetime] | Omitrrrrrrr bool | OmitrrrrrLiteral['asc', 'desc'] | OmitrrrEList[Literal['rescheduling', 'running', 'idle', 'terminated']] | OmitrXrrYrrZrr[rr\rrz(SyncPageCursor[BetaManagedAgentsSession]rrcrXrrYrrZrr[rr\rrr<__name__ __module__ __qualname__r(rFrIrKrOrSrrrxrrrrrrGrEr=r=4s$$''%%--33+/EI&*0415)-$("&;DJ +J  J ( J C J $J .J /J &J "J  J 9J "!J `26)-$("&;D- - / - &- "-  - 9-  "- f?C&*0415)-$("&;DA A < A $ A . A /A &A "A  A 9A  "A L $$(596:596:(, &*/3Z^15)-$("&;D+f f " f 3 f 4 f 3f 4f &f f $f -f f Xf /f $&%f &"'f ( )f *9+f , 2-f X26)-$("&;D- - / - &- "-  - 9-  )- f26)-$("&;D- - / - &- "-  - 9-  "- rGceZdZeddZeddZeddZeddZeddZe e e e e ddde d ddZ e ddde d  dd Z e e e e ddde d  dd Z 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|jSrA)rrBrCs rErFzAsyncSessions.eventss4<<((rGc,t|jSrA)r#rBrCs rErIzAsyncSessions.resourcessdll++rGc,t|jSrA)r5rBrCs rErKzAsyncSessions.threadssDLL))rGct|SrM)AsyncSessionsWithRawResponserCs rErOzAsyncSessions.with_raw_responses,D11rGct|SrQ)"AsyncSessionsWithStreamingResponserCs rErSz%AsyncSessions.with_streaming_responses2$77rGNrTc ^Kitdt|r#djtd|Ddgnti|xsi}ddi|xsi}|j dt ||||||dtjd{t|| | | t d{S7$7w) r^r_r`c32K|]}t|ywrArbrds rErgz'AsyncSessions.create..*rhrirjrkrlNrorp) r rrtr rrur!r0rvr3r;rws rErxzAsyncSessions.creates\  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ $,"&4 (!*"!* &99  )+Q[el-!      s$BB-B) B-$B+%B-+B-ryc @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) r{r|r_r`c32K|]}t|ywrArbrds rErgz)AsyncSessions.retrieve..drhrirjr~rrorNrrs rErzAsyncSessions.retrieveEs4XYcXfgh 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_r`c32K|]}t|ywrArbrds rErgz'AsyncSessions.update..rhrirjr~rrNrorp) rr rrtr rrurr!r1rr3r;rs rErzAsyncSessions.updatetsLXYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ ?J W, ("!* &99 )+Q[el-     s$BCC C<C=CCrcRitdt| r#djtd| Ddgnti|xsi}ddi|xsi}|j dt tt||||t||||||||| | | | d tjtS) rr_r`c32K|]}t|ywrArbrds rErgz%AsyncSessions.list..rhrirjrkrrr) r rrtr rrr.r;r3rr/rrs rErzAsyncSessions.lists@  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $ !9:(+'%%$,)6)6*8)6*8,.>rhrirjr~rrorNrrs rErzAsyncSessions.deletes4XYcXfgh 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_r`c32K|]}t|ywrArbrds rErgz(AsyncSessions.archive..mrhrirjrrrorNrrs rErzAsyncSessions.archiveNs4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ GT^ _(+Q[el-      r)rr)rr#)rr5)rr)rrrrr)$rrrrrrrrrrrrrrrrrrrrrrrrrXrrYrrZrr[rr\rrzSAsyncPaginator[BetaManagedAgentsSession, AsyncPageCursor[BetaManagedAgentsSession]]rrrrGrEr>r>s)),,**2288+/EI&*0415)-$("&;DJ +J  J ( J C J $J .J /J &J "J  J 9J "!J `26)-$("&;D- - / - &- "-  - 9-  "- f?C&*0415)-$("&;DA A < A $ A . A /A &A "A  A 9A  "A L $$(596:596:(, &*/3Z^15)-$("&;D+f f " f 3 f 4 f 3f 4f &f f $f -f f Xf /f $&%f &"'f ( )f *9+f , ]-f X26)-$("&;D- - / - &- "-  - 9-  )- f26)-$("&;D- - / - &- "-  - 9-  "- rGcJeZdZddZeddZeddZed dZy) rNc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrA) _sessionsr to_raw_response_wrapperrxrrrrrrDsessionss rE__init__z SessionsWithRawResponse.__init__s!&>> OO  )@@     '>> OO  %<< MM  '>> OO  (??     rGc@t|jjSrA)rrrFrCs rErFzSessionsWithRawResponse.eventss$T^^%:%:;;rGc@t|jjSrA)r$rrIrCs rErIz!SessionsWithRawResponse.resourcess'(@(@AArGc@t|jjSrA)r6rrKrCs rErKzSessionsWithRawResponse.threadss%dnn&<&<==rGNrr=rNone)rr)rr$)rr6rrrrr(rFrIrKrrGrErNrN~sE ,<<BB>>rGrNcJeZdZddZeddZeddZed dZy) rc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrA) rr async_to_raw_response_wrapperrxrrrrrrs rErz%AsyncSessionsWithRawResponse.__init__s!&DD OO  )FF     'DD OO  %BB MM  'DD OO  (EE     rGc@t|jjSrA)rrrFrCs rErFz#AsyncSessionsWithRawResponse.eventss)$..*?*?@@rGc@t|jjSrA)r%rrIrCs rErIz&AsyncSessionsWithRawResponse.resourcess,T^^-E-EFFrGc@t|jjSrA)r7rrKrCs rErKz$AsyncSessionsWithRawResponse.threadss*4>>+A+ABBrGNrr>rr)rr)rr%)rr7rrrGrErrsI ,AAGGCCrGrcJeZdZddZeddZeddZed dZy) rRcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrA)rr+rxrrrrrrs rErz&SessionsWithStreamingResponse.__init__s!2 OO  5     3 OO  1 MM  3 OO  4     rGc@t|jjSrA)rrrFrCs rErFz$SessionsWithStreamingResponse.eventss*4>>+@+@AArGc@t|jjSrA)r&rrIrCs rErIz'SessionsWithStreamingResponse.resourcess-dnn.F.FGGrGc@t|jjSrA)r8rrKrCs rErKz%SessionsWithStreamingResponse.threadss+DNN,B,BCCrGNr)rr)rr&)rr8rrrGrErRrRsI ,BBHHDDrGrRcJeZdZddZeddZeddZed dZy) rcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrA)rr,rxrrrrrrs rErz+AsyncSessionsWithStreamingResponse.__init__s!8 OO  ;     9 OO  7 MM  9 OO  :     rGc@t|jjSrA)rrrFrCs rErFz)AsyncSessionsWithStreamingResponse.eventss/0E0EFFrGc@t|jjSrA)r'rrIrCs rErIz,AsyncSessionsWithStreamingResponse.resourcess24>>3K3KLLrGc@t|jjSrA)r9rrKrCs rErKz*AsyncSessionsWithStreamingResponse.threads s01G1GHHrGNr)rr)rr')rr9rrrGrErrsI ,GGMMIIrGr)S __future__rtypingrrrrrr itertoolsr typing_extensionsr httpxr rFrrrrrr_typesrrrrrrrr_utilsrrrr r!rIr"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<__all__r=r>rNrrRrrrGrErs#88% !]\\gg(;Z:\\A>O^  'b b J b $b J !>!>H!C!CH!D!DH!I!IrG