o 6Wj@sddlmZddlmZmZmZmZmZddlmZddl 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@mAZAmBZBmCZCmDZDmEZEddlFmGZGddlHmIZIddlJmKZKddlLmMZMddgZNGddde0ZOGddde1ZPGdddZQGdd d ZRGd!d"d"ZSGd#d$d$ZTdS)%) 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 AsyncSessionsc@ eZdZedQddZedRddZedSd d ZedTd d ZedUddZe e e e e ddde d dVd*d+Z e ddde d,dWd.d/Z e e e e e ddde d0 dXd3d4Z e e e e e e e e e e e e e e ddde d5dYdJdKZe ddde d,dZdMdNZe ddde d,dWdOdPZdS)[r=returnrcC t|jSN)r_clientselfrFy/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anthropic/resources/beta/sessions/sessions.pyevents: zSessions.eventsr!cCrArB)r!rCrDrFrFrG resources>rIzSessions.resourcesr3cCrArB)r3rCrDrFrFrGthreadsBrIzSessions.threadsSessionsWithRawResponsecCt|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 )rLrDrFrFrGwith_raw_responseFzSessions.with_raw_responseSessionsWithStreamingResponsecCrMz 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 )rQrDrFrFrGwith_streaming_responsePz Sessions.with_streaming_responseN metadatarJtitle vault_idsbetas extra_headers extra_query extra_bodytimeoutagentsession_create_params.Agentenvironment_idstrrVDict[str, str] | OmitrJ/Iterable[session_create_params.Resource] | OmitrWOptional[str] | OmitrXSequenceNotStr[str] | OmitrYList[AnthropicBetaParam] | OmitrZHeaders | Noner[ Query | Noner\ Body | Noner]'float | httpx.Timeout | None | NotGivenr:c Csitdt|rdtdd|Ddgnti|pi}ddi|p$i}|jdt||||||dtjt || | | dt d S) >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,cs|]}t|VqdSrBra.0erFrFrG z"Sessions.create..managed-agents-2026-04-01/v1/sessions?beta=truer^r`rVrJrWrXrZr[r\r]bodyoptionscast_to) rrjoinr r_postrr/SessionCreateParamsr2r: rEr^r`rVrJrWrXrYrZr[r\r]rFrFrGcreateYs:.  zSessions.createrYrZr[r\r] session_idcC|s td|itdt|rdtdd|Ddgnti|p%i}ddi|p-i}|jtd|dt||||d t d 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 rlrmcsrnrBrorprFrFrGrsrtz$Sessions.retrieve..ru#/v1/sessions/{session_id}?beta=truerrxr{r| ValueErrorrrr}r r_getrr2r:rErrYrZr[r\r]rFrFrGretrieve*  zSessions.retrieve r^rVrWrXrYrZr[r\r]/BetaManagedAgentsSessionAgentUpdateParam | Omit)Optional[Dict[str, Optional[str]]] | Omitc Cs|s td|itdt|rdtdd|Ddgnti|p%i}ddi|p-i}|jtd|dt||||d t j t ||| | d t d 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 rrlrmcsrnrBrorprFrFrGrsrtz"Sessions.update..rurrr^rVrWrXrxry) rrrr}r rr~rrr0SessionUpdateParamsr2r: rErr^rVrWrXrYrZr[r\r]rFrFrGupdates:+   zSessions.updateagent_id agent_version created_at_gtcreated_at_gte created_at_ltcreated_at_lte deployment_idinclude_archivedlimitmemory_store_idorderpagestatusesrYrZr[r\r]r str | Omitr int | OmitrUnion[str, datetime] | Omitrrrrr bool | OmitrrrLiteral['asc', 'desc'] | OmitrrEList[Literal['rescheduling', 'running', 'idle', 'terminated']] | Omit5SyncBidirectionalPageCursor[BetaManagedAgentsSession]cCitdt|rdtdd|Ddgnti|pi}ddi|p$i}|jdttt||||t ||||||||| | | | | d t j dtd S)  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 rlrmcsrnrBrorprFrFrGrscrtz Sessions.list..rurv rrrrrrrrrrrrrrZr[r\r]queryrr{model) rrr}r r _get_api_listr,r:r2rr.SessionListParamsrErrrrrrrrrrrrrrYrZr[r\r]rFrFrGlistPC z Sessions.listr;cCr)  Delete 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 rrlrmcsrnrBrorprFrFrGrsrtz"Sessions.delete..rurrrxr rrrr}r r_deleterr2r;rrFrFrGdeleterzSessions.deletecCr)  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 rrlrmcsrnrBrorprFrFrGrsrtz#Sessions.archive..ru+/v1/sessions/{session_id}/archive?beta=truerrxr rrrr}r rr~rr2r:rrFrFrGarchiverzSessions.archive)r@r)r@r!)r@r3)r@rL)r@rQr^r_r`rarVrbrJrcrWrdrXrerYrfrZrgr[rhr\rir]rjr@r:rrarYrfrZrgr[rhr\rir]rjr@r:rrar^rrVrrWrdrXrerYrfrZrgr[rhr\rir]rjr@r:)&rrrrrrrrrrrrrrrrrrrrrrrrrrrYrfrZrgr[rhr\rir]rjr@rrrarYrfrZrgr[rhr\rir]rjr@r;__name__ __module__ __qualname__r'rHrJrKrOrSrrrrrrrrrFrFrFrGr=9      P3Lp3c@r?)[r>r@rcCrArB)rrCrDrFrFrGrHrIzAsyncSessions.eventsr"cCrArB)r"rCrDrFrFrGrJrIzAsyncSessions.resourcesr4cCrArB)r4rCrDrFrFrGrKrIzAsyncSessions.threadsAsyncSessionsWithRawResponsecCrMrN)rrDrFrFrGrOrPzAsyncSessions.with_raw_response"AsyncSessionsWithStreamingResponsecCrMrR)rrDrFrFrGrSrTz%AsyncSessions.with_streaming_responseNrUr^r_r`rarVrbrJrcrWrdrXrerYrfrZrgr[rhr\rir]rjr:c sitdt|rdtdd|Ddgnti|pi}ddi|p%i}|jdt||||||dtjIdHt || | | d t d IdHS) rkrlrmcsrnrBrorprFrFrGrs9rtz'AsyncSessions.create..rurvrwNrxry) rrr}r rr~r r/rr2r:rrFrFrGrs<.   zAsyncSessions.createrrc|s td|itdt|rdtdd|Ddgnti|p&i}ddi|p.i}|jtd|dt||||d t d Id HS) rrrlrmcsrnrBrorprFrFrGrssrtz)AsyncSessions.retrieve..rurrrxrNrrrFrFrGrT,   zAsyncSessions.retrieverrrc s|s td|itdt|rdtdd|Ddgnti|p&i}ddi|p.i}|jtd|dt||||d t j Id Ht ||| | d t d Id HS) rrrlrmcsrnrBrorprFrFrGrsrtz'AsyncSessions.update..rurrrNrxry) rrrr}r rr~rr r0rr2r:rrFrFrGrs<+    zAsyncSessions.updaterrrrrrrrrrrrrrrrrrrr`AsyncPaginator[BetaManagedAgentsSession, AsyncBidirectionalPageCursor[BetaManagedAgentsSession]]cCr) rrlrmcsrnrBrorprFrFrGrsrtz%AsyncSessions.list..rurvrrr) rrr}r rrr-r:r2rr.rrrFrFrGrrzAsyncSessions.listr;cr) rrrlrmcsrnrBrorprFrFrGrsWrtz'AsyncSessions.delete..rurrrxrNrrrFrFrGr8rzAsyncSessions.deletecr) rrrlrmcsrnrBrorprFrFrGrsrtz(AsyncSessions.archive..rurrrxrNrrrFrFrGrgrzAsyncSessions.archive)r@r)r@r")r@r4)r@r)r@rrrr)&rrrrrrrrrrrrrrrrrrrrrrrrrrrYrfrZrgr[rhr\rir]rjr@rrrrFrFrFrGr>rc@@eZdZdddZeddd Zedd d ZedddZdS)rLsessionsr=r@NonecC^||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSrB) _sessionsr to_raw_response_wrapperrrrrrrrErrFrFrG__init__& z SessionsWithRawResponse.__init__rcC t|jjSrB)rrrHrDrFrFrGrH zSessionsWithRawResponse.eventsr#cCrrB)r#rrJrDrFrFrGrJrz!SessionsWithRawResponse.resourcesr5cCrrB)r5rrKrDrFrFrGrKrzSessionsWithRawResponse.threadsNrr=r@r)r@r)r@r#)r@r5rrrrr'rHrJrKrFrFrFrGrL   rLc@r)rrr>r@rcCrrB) rr async_to_raw_response_wrapperrrrrrrrrFrFrGrrz%AsyncSessionsWithRawResponse.__init__rcCrrB)rrrHrDrFrFrGrHrz#AsyncSessionsWithRawResponse.eventsr$cCrrB)r$rrJrDrFrFrGrJrz&AsyncSessionsWithRawResponse.resourcesr6cCrrB)r6rrKrDrFrFrGrKrz$AsyncSessionsWithRawResponse.threadsNrr>r@r)r@r)r@r$)r@r6rrFrFrFrGrrrc@r)rQrr=r@rcCR||_t|j|_t|j|_t|j|_t|j|_t|j|_t|j|_dSrB)rr*rrrrrrrrFrFrGr& z&SessionsWithStreamingResponse.__init__rcCrrB)rrrHrDrFrFrGrHrz$SessionsWithStreamingResponse.eventsr%cCrrB)r%rrJrDrFrFrGrJrz'SessionsWithStreamingResponse.resourcesr7cCrrB)r7rrKrDrFrFrGrKrz%SessionsWithStreamingResponse.threadsNr)r@r)r@r%)r@r7rrFrFrFrGrQrrQc@r)rrr>r@rcCrrB)rr+rrrrrrrrFrFrGrrz+AsyncSessionsWithStreamingResponse.__init__rcCrrB)rrrHrDrFrFrGrHrz)AsyncSessionsWithStreamingResponse.eventsr&cCrrB)r&rrJrDrFrFrGrJrz,AsyncSessionsWithStreamingResponse.resourcesr8cCrrB)r8rrKrDrFrFrGrK"rz*AsyncSessionsWithStreamingResponse.threadsNr)r@r)r@r&)r@r8rrFrFrFrGrrr)U __future__rtypingrrrrrr itertoolsr typing_extensionsr httpxr rHrrrrrr_typesrrrrrrrr_utilsrrrrr rJr!r"r#r$r%r&_compatr' _resourcer(r) _responser*r+ paginationr,r- types.betar.r/r0 _base_clientr1r2threads.threadsr3r4r5r6r7r8types.anthropic_beta_paramr9&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>rLrrQrrFrFrFrGsF      (       22$$$