Á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@mAZAmBZBmCZCmDZDmEZEddlFmGZGddlHmIZIddlJmKZKddlLmMZMddlNmOZOddgZPGdde0ZQGdde1ZRGddZSGd d!ZTGd"d#ZUGd$d%ZVy)&) 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)!BetaManagedAgentsBudgetLimitParam)(BetaManagedAgentsSessionAgentUpdateParamSessions AsyncSessionsceZdZeddZeddZeddZeddZeddZe e e e e e e ddde d ddZ e ddde d  dd Z e 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 Q/tmp/pip-target-k_scjv0h/lib/python/anthropic/resources/beta/sessions/sessions.pyeventszSessions.events;sdll##c,t|jSrC)r"rDrEs rG resourceszSessions.resources?s&&rIc,t|jSrC)r4rDrEs rGthreadszSessions.threadsCst||$$rIct|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 )SessionsWithRawResponserEs rGwith_raw_responsezSessions.with_raw_responseGs't,,rIct|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 )SessionsWithStreamingResponserEs rGwith_streaming_responsez Sessions.with_streaming_responseQs-T22rIN budgetinitial_eventsmetadatarKtitle vault_idsbetas extra_headers extra_query extra_bodytimeoutc 2itdt| 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. budget: A hard spend ceiling. The session stops issuing new model requests once the tracked list cost reaches `max_list_cost`. initial_events: Initial events to send to the `session` at creation, processed in order. Supports `user.message` and `user.define_outcome` events. Maximum 50 events. 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|ywrCstr.0es rG z"Sessions.create..5Lc!f5Lmanaged-agents-2026-04-01/v1/sessions?beta=trueagentenvironment_idrWrXrYrKrZr[r]r^r_r`bodyoptionscast_to) r rjoinr r_postrr0SessionCreateParamsr3r;rFrqrrrWrXrYrKrZr[r\r]r^r_r`s rGcreatezSessions.createZsl  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz $ "&4$&4 (!*"!* &99 )+Q[el-%  rIr\r]r^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 rcrdc32K|]}t|ywrCrfrhs rGrkz$Sessions.retrieve..rlrmrn#/v1/sessions/{session_id}?beta=true session_idrsrvrw ValueErrorr rrxr r_getrr3r;rFrr\r]r^r_r`s rGretrievezSessions.retrieves4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` yy ?J W(+Q[el-   rI rqrWrYrZr[r\r]r^r_r`c b|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. budget: A hard spend ceiling. The session stops issuing new model requests once the tracked list cost reaches `max_list_cost`. 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 rrcrdc32K|]}t|ywrCrfrhs rGrkz"Sessions.update..rlrmrnrrrqrWrYrZr[rsrt) rr rrxr rryrrr1SessionUpdateParamsr3r; rFrrqrWrYrZr[r\r]r^r_r`s rGupdatezSessions.updates^XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz ?J W "$ ("!* &99 )+Q[el-  rIagent_id agent_version created_at_gtcreated_at_gte created_at_ltcreated_at_lte deployment_idinclude_archivedlimitmemory_store_idorderpagestatusesr\r]r^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 rcrdc32K|]}t|ywrCrfrhs rGrkz Sessions.list..srlrmrnro rrrrrrrrrrrrrr]r^r_r`queryrrvmodel) r rrxr r _get_api_listr-r;r3rr/SessionListParamsrFrrrrrrrrrrrrrr\r]r^r_r`s rGlistz Sessions.list-sF  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $,-EF(+'%%$,)6)6*8)6*8)6,.rlrmrnrrrsr rr rrxr r_deleterr3r<rs rGdeletezSessions.deletes4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` || ?J W(+Q[el4   rIc $|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 rrcrdc32K|]}t|ywrCrfrhs rGrkz#Sessions.archive..rlrmrn+/v1/sessions/{session_id}/archive?beta=truerrsr rr rrxr rryrr3r;rs rGarchivezSessions.archives4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` zz GT^ _(+Q[el-   rI)returnr)rr")rr4)rrP)rrTrqzsession_create_params.AgentrrrgrWz(BetaManagedAgentsBudgetLimitParam | OmitrXz3Iterable[session_create_params.InitialEvent] | OmitrYzDict[str, str] | OmitrKz/Iterable[session_create_params.Resource] | OmitrZOptional[str] | Omitr[SequenceNotStr[str] | Omitr\List[AnthropicBetaParam] | Omitr]Headers | Noner^ Query | Noner_ Body | Noner`'float | httpx.Timeout | None | NotGivenrr;rrgr\rr]rr^rr_rr`rrr;rrgrqz/BetaManagedAgentsSessionAgentUpdateParam | OmitrWz2Optional[BetaManagedAgentsBudgetLimitParam] | OmitrYz)Optional[Dict[str, Optional[str]]] | OmitrZrr[rr\rr]rr^rr_rr`rrr;)&r str | Omitr int | OmitrUnion[str, datetime] | Omitrrrrrrrrr bool | OmitrrrrrLiteral['asc', 'desc'] | OmitrrrEList[Literal['rescheduling', 'running', 'idle', 'terminated']] | Omitr\rr]rr^rr_rr`rrz5SyncBidirectionalPageCursor[BetaManagedAgentsSession]rrgr\rr]rr^rr_rr`rrr<__name__ __module__ __qualname__r(rHrKrMrQrUrrr|rrrrrrIrGr?r?:s$$''%%--33<@NR*.EI&*0415)-$("&;D#T +T  T 9 T L T (T CT $T .T /T &T "T  !T "9#T $ "%T t26)-$("&;D- - / - &- "-  - 9-  "- fBFEI>B&*0415)-$("&;DL L ? L C L < L $L .L /L &L "L  L 9L "!L b $$(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-  "- rIceZdZeddZeddZeddZeddZeddZe e e e e e e ddde d ddZ e ddde d  dd Z e 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|jSrC)rrDrEs rGrHzAsyncSessions.eventss4<<((rIc,t|jSrC)r#rDrEs rGrKzAsyncSessions.resourcessdll++rIc,t|jSrC)r5rDrEs rGrMzAsyncSessions.threadssDLL))rIct|SrO)AsyncSessionsWithRawResponserEs rGrQzAsyncSessions.with_raw_responses,D11rIct|SrS)"AsyncSessionsWithStreamingResponserEs rGrUz%AsyncSessions.with_streaming_responses2$77rINrVc bKitdt| r#djtd| Ddgnti| xsi} ddi| xsi} |j dt ||||||||dtjd{t| | | | t d{S7$7w) rbrcrdc32K|]}t|ywrCrfrhs rGrkz'AsyncSessions.create..QrlrmrnrorpNrsrt) r rrxr rryr!r0rzr3r;r{s rGr|zAsyncSessions.createsl  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ $,"&4$&4 (!*"!* &99  )+Q[el-%      s$BB/B+ B/&B-'B/-B/r}c @K|std|itdt|r#djt d|Ddgnt i|xsi}ddi|xsi}|j td|t||||t d {S7w) rrrcrdc32K|]}t|ywrCrfrhs rGrkz)AsyncSessions.retrieve..rlrmrnrrrsrNrrs rGrzAsyncSessions.retrievens4XYcXfgh 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) rrrcrdc32K|]}t|ywrCrfrhs rGrkz'AsyncSessions.update..rlrmrnrrrNrsrt) rr rrxr rryrr!r1rr3r;rs rGrzAsyncSessions.updates^XYcXfgh 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) rrcrdc32K|]}t|ywrCrfrhs rGrkz%AsyncSessions.list..1rlrmrnrorrr) r rrxr rrr.r;r3rr/rrs rGrzAsyncSessions.listsF  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` !! $-.FG(+'%%$,)6)6*8)6*8)6,.vrlrmrnrrrsrNrrs rGrzAsyncSessions.deleteWs4XYcXfgh 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) rrrcrdc32K|]}t|ywrCrfrhs rGrkz(AsyncSessions.archive..rlrmrnrrrsrNrrs rGrzAsyncSessions.archives4XYcXfgh h  $'*hhu5Le5LOjNk/l&m"  "  *+F`=K^\^` ZZ GT^ _(+Q[el-      r)rr)rr#)rr5)rr)rrrrr)&rrrrrrrrrrrrrrrrrrrrrrrrrrr\rr]rr^rr_rr`rrz`AsyncPaginator[BetaManagedAgentsSession, AsyncBidirectionalPageCursor[BetaManagedAgentsSession]]rrrrIrGr@r@s)),,**2288<@NR*.EI&*0415)-$("&;D#T +T  T 9 T L T (T CT $T .T /T &T "T  !T "9#T $ "%T t26)-$("&;D- - / - &- "-  - 9-  "- fBFEI>B&*0415)-$("&;DL L ? L C L < L $L .L /L &L "L  L 9L "!L b $$(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-  "- rIcJeZdZddZeddZeddZed dZy) rPc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrC) _sessionsr to_raw_response_wrapperr|rrrrrrFsessionss rG__init__z SessionsWithRawResponse.__init__s!&>> OO  )@@     '>> OO  %<< MM  '>> OO  (??     rIc@t|jjSrC)rrrHrEs rGrHzSessionsWithRawResponse.eventss$T^^%:%:;;rIc@t|jjSrC)r$rrKrEs rGrKz!SessionsWithRawResponse.resourcess'(@(@AArIc@t|jjSrC)r6rrMrEs rGrMzSessionsWithRawResponse.threadss%dnn&<&<==rINrr?rNone)rr)rr$)rr6rrrrr(rHrKrMrrIrGrPrPsE ,<<BB>>rIrPcJeZdZddZeddZeddZed dZy) rc||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_yrC) rr async_to_raw_response_wrapperr|rrrrrrs rGrz%AsyncSessionsWithRawResponse.__init__s!&DD OO  )FF     'DD OO  %BB MM  'DD OO  (EE     rIc@t|jjSrC)rrrHrEs rGrHz#AsyncSessionsWithRawResponse.eventss)$..*?*?@@rIc@t|jjSrC)r%rrKrEs rGrKz&AsyncSessionsWithRawResponse.resourcess,T^^-E-EFFrIc@t|jjSrC)r7rrMrEs rGrMz$AsyncSessionsWithRawResponse.threadss*4>>+A+ABBrINrr@rr)rr)rr%)rr7rrrIrGrrsI ,AAGGCCrIrcJeZdZddZeddZeddZed dZy) rTcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrC)rr+r|rrrrrrs rGrz&SessionsWithStreamingResponse.__init__s!2 OO  5     3 OO  1 MM  3 OO  4     rIc@t|jjSrC)rrrHrEs rGrHz$SessionsWithStreamingResponse.eventss*4>>+@+@AArIc@t|jjSrC)r&rrKrEs rGrKz'SessionsWithStreamingResponse.resourcess-dnn.F.FGGrIc@t|jjSrC)r8rrMrEs rGrMz%SessionsWithStreamingResponse.threadss+DNN,B,BCCrINr)rr)rr&)rr8rrrIrGrTrTsI ,BBHHDDrIrTcJeZdZddZeddZeddZed dZy) rcJ||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_yrC)rr,r|rrrrrrs rGrz+AsyncSessionsWithStreamingResponse.__init__#s!8 OO  ;     9 OO  7 MM  9 OO  :     rIc@t|jjSrC)rrrHrEs rGrHz)AsyncSessionsWithStreamingResponse.events9s/0E0EFFrIc@t|jjSrC)r'rrKrEs rGrKz,AsyncSessionsWithStreamingResponse.resources=s24>>3K3KLLrIc@t|jjSrC)r9rrMrEs rGrMz*AsyncSessionsWithStreamingResponse.threadsAs01G1GHHrINr)rr)rr')rr9rrrIrGrr"sI ,GGMMIIrIr)W __future__rtypingrrrrrr itertoolsr typing_extensionsr httpxr rHrrrrrr_typesrrrrrrrr_utilsrrrr r!rKr"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<1types.beta.beta_managed_agents_budget_limit_paramr=9types.beta.beta_managed_agents_session_agent_update_paramr>__all__r?r@rPrrTrrrIrGrs#88% !]\\gg(;ZT B>O^cr  '{ { | { ${ | !>!>H!C!CH!D!DH!I!IrI