܎j3NddlmZddlmZmZmZmZmZddlmZddl 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%ZVdS)&) 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 AsyncSessionsc:eZdZedKdZedLdZedMdZedNd ZedOd Ze e e e e e e d d d e d dPd)Z e d d d e d*dQd,Z e e e e e e d d d e d- dRd1Z e e e e e e e e e e e e e e d d d e d2dSdGZe d d d e d*dTdIZe d d d e d*dQdJZd S)Ur?returnrc*t|jSN)r_clientselfs XC:\Projects\DSCons\.venv\Lib\site-packages\anthropic\resources\beta\sessions\sessions.pyeventszSessions.events;sdl###r"c*t|jSrD)r"rErFs rH resourceszSessions.resources?s&&&rJr4c*t|jSrD)r4rErFs rHthreadszSessions.threadsCst|$$$rJSessionsWithRawResponsec t|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 )rOrFs rHwith_raw_responsezSessions.with_raw_responseGs't,,,rJSessionsWithStreamingResponsec t|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 )rSrFs rHwith_streaming_responsez Sessions.with_streaming_responseQs-T222rJN budgetinitial_eventsmetadatarLtitle vault_idsbetas extra_headers extra_query extra_bodytimeoutagentsession_create_params.Agentenvironment_idstrrX(BetaManagedAgentsBudgetLimitParam | OmitrY3Iterable[session_create_params.InitialEvent] | OmitrZDict[str, str] | OmitrL/Iterable[session_create_params.Resource] | Omitr[Optional[str] | Omitr\SequenceNotStr[str] | Omitr]List[AnthropicBetaParam] | Omitr^Headers | Noner_ Query | Noner` Body | Nonera'float | httpx.Timeout | None | NotGivenr;c ditdt| r.dtd| Ddgnti| pi} ddi| pi} |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,c34K|]}t|VdSrDre.0es rH z"Sessions.create..(5L5Lc!ff5L5L5L5L5L5LrJmanaged-agents-2026-04-01/v1/sessions?beta=truerbrdrXrYrZrLr[r\r^r_r`rabodyoptionscast_to) r rjoinr r_postrr0SessionCreateParamsr3r;rGrbrdrXrYrZrLr[r\r]r^r_r`ras rHcreatezSessions.createZsl  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` zz $ "&4$&4 (!*"!*  &9  )+Q[el-%   rJr]r^r_r`ra session_idc f|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|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 rsrtc34K|]}t|VdSrDrvrws rHrzz$Sessions.retrieve..r{rJr|#/v1/sessions/{session_id}?beta=truerrrr ValueErrorr rrr r_getrr3r;rGrr]r^r_r`ras rHretrievezSessions.retrieves4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` yy ?J W W W(+Q[el-    rJ rbrXrZr[r\r]r^r_r`ra/BetaManagedAgentsSessionAgentUpdateParam | Omit2Optional[BetaManagedAgentsBudgetLimitParam] | Omit)Optional[Dict[str, Optional[str]]] | Omitc |std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|td|t|||||dtj t|| | | 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 rrsrtc34K|]}t|VdSrDrvrws rHrzz"Sessions.update..r{rJr|rrrbrXrZr[r\rr) rr rrr rrrrr1SessionUpdateParamsr3r; rGrrbrXrZr[r\r]r^r_r`ras rHupdatezSessions.updates+^ igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` zz ?J W W W "$ ("!* &9  )+Q[el-   rJagent_id agent_version created_at_gtcreated_at_gte created_at_ltcreated_at_lte deployment_idinclude_archivedlimitmemory_store_idorderpagestatusesr]r^r_r`rar str | Omitr int | OmitrUnion[str, datetime] | Omitrrrrr bool | OmitrrrLiteral['asc', 'desc'] | OmitrrEList[Literal['rescheduling', 'running', 'idle', 'terminated']] | Omit5SyncBidirectionalPageCursor[BetaManagedAgentsSession]citdt|r.dtd|Ddgnti|pi}ddi|pi}|dt tt||||t||||||||| | | | | d tj tS)  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 rsrtc34K|]}t|VdSrDrvrws rHrzz Sessions.list..sr{rJr|r} rrrrrrrrrrrrrr^r_r`raqueryrrmodel) r rrr r _get_api_listr-r;r3rr/SessionListParamsrGrrrrrrrrrrrrrr]r^r_r`ras rHlistz Sessions.list-sF  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` !! $,-EF(+'%%$,)6)6*8)6*8)6,.r{rJr|rrrr rr rrr r_deleterr3r<rs rHdeletezSessions.deletes4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` || ?J W W W(+Q[el4    rJc f|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|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 rrsrtc34K|]}t|VdSrDrvrws rHrzz#Sessions.archive..r{rJr|+/v1/sessions/{session_id}/archive?beta=truerrr rr rrr rrrr3r;rs rHarchivezSessions.archives4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` zz GT^ _ _ _(+Q[el-    rJ)rBr)rBr")rBr4)rBrO)rBrSrbrcrdrerXrfrYrgrZrhrLrir[rjr\rkr]rlr^rmr_rnr`rorarprBr;rrer]rlr^rmr_rnr`rorarprBr;rrerbrrXrrZrr[rjr\rkr]rlr^rmr_rnr`rorarprBr;)&rrrrrrrrrrrrrrrrrrrrrrrrrrr]rlr^rmr_rnr`rorarprBrrrer]rlr^rmr_rnr`rorarprBr<__name__ __module__ __qualname__r(rIrLrNrRrVrrrrrrrrrJrHr?r?:s:$$$_$'''_'%%%_%---_-333_3<@NR*.EI&*0415)-$("&;D#T T T T T T t26)-$("&;D- - - - - - fBFEI>B&*0415)-$("&;DL L L L L L b $$(596:596:$((, &*/3Z^15)-$("&;D-j j j j j j `26)-$("&;D- - - - - - f26)-$("&;D- - - - - - - - rJc:eZdZedKdZedLdZedMdZedNd ZedOd Ze e e e e e e d d d e d dPd)Z e d d d e d*dQd,Z e e e e e e d d d e d- dRd1Z e e e e e e e e e e e e e e d d d e d2dSdGZe d d d e d*dTdIZe d d d e d*dQdJZd S)Ur@rBrc*t|jSrD)rrErFs rHrIzAsyncSessions.eventss4<(((rJr#c*t|jSrD)r#rErFs rHrLzAsyncSessions.resourcessdl+++rJr5c*t|jSrD)r5rErFs rHrNzAsyncSessions.threadssDL)))rJAsyncSessionsWithRawResponsec t|SrQ)rrFs rHrRzAsyncSessions.with_raw_responses,D111rJ"AsyncSessionsWithStreamingResponsec t|SrU)rrFs rHrVz%AsyncSessions.with_streaming_responses2$777rJNrWrbrcrdrerXrfrYrgrZrhrLrir[rjr\rkr]rlr^rmr_rnr`rorarpr;c Kitdt| r.dtd| Ddgnti| pi} ddi| pi} |dt ||||||||dtjd{Vt| | | | t d{VS) rrrsrtc34K|]}t|VdSrDrvrws rHrzz'AsyncSessions.create..Qr{rJr|r}r~Nrr) r rrr rrr!r0rr3r;rs rHrzAsyncSessions.createsCl  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` ZZ $,"&4$&4 (!*"!*  &9        )+Q[el-%          rJrrc vK|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|td|t||||t d {VS) rrrsrtc34K|]}t|VdSrDrvrws rHrzz)AsyncSessions.retrieve..r{rJr|rrrrNrrs rHrzAsyncSessions.retrievens4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` YY ?J W W W(+Q[el-          rJrrrrc K|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|td|t|||||dtj d {Vt|| | | t d {VS) rrrsrtc34K|]}t|VdSrDrvrws rHrzz'AsyncSessions.update..r{rJr|rrrNrr) rr rrr rrrr!r1rr3r;rs rHrzAsyncSessions.updatesk^ igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` ZZ ?J W W W,"$ ("!* &9        )+Q[el-          rJrrrrrrrrrrrrrrrrrrrr`AsyncPaginator[BetaManagedAgentsSession, AsyncBidirectionalPageCursor[BetaManagedAgentsSession]]citdt|r.dtd|Ddgnti|pi}ddi|pi}|dt tt||||t||||||||| | | | | d tj tS) rrsrtc34K|]}t|VdSrDrvrws rHrzz%AsyncSessions.list..1r{rJr|r}rrr) r rrr rrr.r;r3rr/rrs rHrzAsyncSessions.listsF  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` !! $-.FG(+'%%$,)6)6*8)6*8)6,.vr{rJr|rrrrNrrs rHrzAsyncSessions.deleteWs4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` \\ ?J W W W(+Q[el4 "         rJc vK|std|itdt|r.dt d|Ddgnt i|pi}ddi|pi}|td|t||||t d {VS) rrrsrtc34K|]}t|VdSrDrvrws rHrzz(AsyncSessions.archive..r{rJr|rrrrNrrs rHrzAsyncSessions.archives4 igYcgghh h  $'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m"  "  *+F`=K^\^` ZZ GT^ _ _ _(+Q[el-           rJ)rBr)rBr#)rBr5)rBr)rBrrrr)&rrrrrrrrrrrrrrrrrrrrrrrrrrr]rlr^rmr_rnr`rorarprBrrrrrJrHr@r@s:)))_),,,_,***_*222_2888_8<@NR*.EI&*0415)-$("&;D#T T T T T T t26)-$("&;D- - - - - - fBFEI>B&*0415)-$("&;DL L L L L L b $$(596:596:$((, &*/3Z^15)-$("&;D-j j j j j j `26)-$("&;D- - - - - - f26)-$("&;D- - - - - - - - rJc^eZdZd dZeddZedd Zedd Zd S)rOsessionsr?rBNonec|||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSrD) _sessionsr to_raw_response_wrapperrrrrrrrGrs rH__init__z SessionsWithRawResponse.__init__s!&> O   )@     '> O   %< M   '> O   (?     rJrc4t|jjSrD)rrrIrFs rHrIzSessionsWithRawResponse.eventss$T^%:;;;rJr$c4t|jjSrD)r$rrLrFs rHrLz!SessionsWithRawResponse.resourcess'(@AAArJr6c4t|jjSrD)r6rrNrFs rHrNzSessionsWithRawResponse.threadss%dn&<===rJNrr?rBr)rBr)rBr$)rBr6rrrrr(rIrLrNrrJrHrOrOs    ,<<<_<BBB_B>>>_>>>rJrOc^eZdZd dZeddZedd Zedd Zd S)rrr@rBrc|||_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_tj|j|_dSrD) rr async_to_raw_response_wrapperrrrrrrrs rHrz%AsyncSessionsWithRawResponse.__init__s!&D O   )F     'D O   %B M   'D O   (E     rJrc4t|jjSrD)rrrIrFs rHrIz#AsyncSessionsWithRawResponse.eventss)$.*?@@@rJr%c4t|jjSrD)r%rrLrFs rHrLz&AsyncSessionsWithRawResponse.resourcess,T^-EFFFrJr7c4t|jjSrD)r7rrNrFs rHrNz$AsyncSessionsWithRawResponse.threadss*4>+ABBBrJNrr@rBr)rBr)rBr%)rBr7rrrJrHrrs    ,AAA_AGGG_GCCC_CCCrJrc^eZdZd dZeddZedd Zedd Zd S)rSrr?rBrc@||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSrD)rr+rrrrrrrs rHrz&SessionsWithStreamingResponse.__init__s!2 O   5     3 O   1 M   3 O   4     rJrc4t|jjSrD)rrrIrFs rHrIz$SessionsWithStreamingResponse.eventss*4>+@AAArJr&c4t|jjSrD)r&rrLrFs rHrLz'SessionsWithStreamingResponse.resourcess-dn.FGGGrJr8c4t|jjSrD)r8rrNrFs rHrNz%SessionsWithStreamingResponse.threadss+DN,BCCCrJNr)rBr)rBr&)rBr8rrrJrHrSrSs    ,BBB_BHHH_HDDD_DDDrJrSc^eZdZd dZeddZedd Zedd Zd S)rrr@rBrc@||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSrD)rr,rrrrrrrs rHrz+AsyncSessionsWithStreamingResponse.__init__#s!8 O   ;     9 O   7 M   9 O   :     rJrc4t|jjSrD)rrrIrFs rHrIz)AsyncSessionsWithStreamingResponse.events9s/0EFFFrJr'c4t|jjSrD)r'rrLrFs rHrLz,AsyncSessionsWithStreamingResponse.resources=s24>3KLLLrJr9c4t|jjSrD)r9rrNrFs rHrNz*AsyncSessionsWithStreamingResponse.threadsAs01GHHHrJNr)rBr)rBr')rBr9rrrJrHrr"s    ,GGG_GMMM_MIII_IIIrJr)W __future__rtypingrrrrrr itertoolsr typing_extensionsr httpxr rIrrrrrr_typesrrrrrrrr_utilsrrrr r!rLr"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@rOrrSrrrJrHr s*#"""""88888888888888%%%%%% !!!!!!]\\\\\\\\\\\\\\\\\\\gggggggggggggg(''''';;;;;;;;ZZZZZZZZTTTTTTTT BAAAAAAA>=====OOOOOO^^^^^^ccccccrrrrrr  '{ { { { { { { { | { { { { { ${ { { | !>!>!>!>!>!>!>!>H!C!C!C!C!C!C!C!CH!D!D!D!D!D!D!D!DH!I!I!I!I!I!I!I!I!I!IrJ