"jGSSKJr SSKJrJrJr SSKJr SSKrSSK J r J r J r J r JrJrJr SSKJrJrJr SSKJr SS KJrJr SS KJrJrJrJr SS KJ r J!r! SS K"J#r#J$r$ SS K%J&r&J'r' SSK(J)r) SSK*J+r+ SSK,J-r- SSK.J/r/ SS/r0"SS\5r1"SS\5r2"SS5r3"SS5r4"SS5r5"SS5r6g)) annotations)AnyListcast)chainN)BodyOmitQueryHeadersNotGivenomit not_given)is_given path_templatestrip_not_given)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)AnthropicBetaParam)BetaManagedAgentsDeltaType)BetaManagedAgentsSessionEvent)*BetaManagedAgentsStreamSessionThreadEventsEvents AsyncEventsc \rSrSr\S Sj5r\S Sj5r\\\\SSS\S.S Sjjr \\\SSS\S.S Sjjr S r g)r$c[U5$z 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 )EventsWithRawResponseselfs m/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anthropic/resources/beta/sessions/threads/events.pywith_raw_responseEvents.with_raw_response s%T**c[U5$z 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 )EventsWithStreamingResponser+s r-with_streaming_responseEvents.with_streaming_response*s+400r0Nlimitpagebetas workspace_id extra_headers extra_query extra_bodytimeoutc U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9[[[UUU U UUS .S 9[[[5S 9$)  List Session Thread Events Args: betas: Optional header to specify the beta version(s) you want to use. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 8Expected a non-empty value for `thread_id` but received ,c38# UHn[U5v M g7fNstr.0es r- Events.list.._5Lec!ffemanaged-agents-2026-04-01anthropic-betazanthropic-workspace-idrQ>/v1/sessions/{session_id}/threads/{thread_id}/events?beta=true session_id thread_idr7r8r;r<r=r>queryr8optionsmodel) ValueErrorrrjoinrr _get_api_listrrr"rrr r,rUrTr7r8r9r:r;r<r=r>s r-list Events.list3sJXYcXfgh hWXaWdef f   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` !! P%#   =>(+'%"  2#"  r0 event_deltasr9r:r;r<r=r>c U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9[UUUU S U0S 9[[[5S [[S 9$) Stream Session Thread Events Args: event_deltas: When set, this connection also receives streaming deltas (`event_start`, `event_delta`) while an event is being produced, before the event itself arrives. Deltas are best-effort; when the final event is produced it carries the complete content. A model request that ends early (an error or interrupt) produces no final event — its terminal `span.model_request_end` closes the preview. Accepts one or more event types to preview and may be repeated: `agent.message` streams `content_delta` fragments; `agent.thinking` is start-only — a signal that the agent has begun extended thinking, concluded by the `agent.thinking` event itself. Only previews of the requested event types are sent. betas: Optional header to specify the beta version(s) you want to use. workspace_id: Optional header to select the Workspace for this request. The value is a Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`). Only needed for credentials that can act on more than one Workspace. A credential that belongs to a specific Workspace may omit it; if sent, it must match that Workspace. 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 rArBrCc38# UHn[U5v M g7frErFrHs r-rK Events.stream..rMrNrOrPrQ>/v1/sessions/{session_id}/threads/{thread_id}/stream?beta=truerSrcrWTrZcast_tostream stream_cls) r\rrr]rr_getrrrrr#r r,rUrTrcr9r:r;r<r=r>s r-rk Events.stream~s^XYcXfgh hWXaWdef f   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` yy P%#  )+'%%|4 ?HI#  r0)returnr*)rqr3)rUrGrTrGr7 int | Omitr8 str | Omitr9List[AnthropicBetaParam] | Omitr:rsr;Headers | Noner< Query | Noner= Body | Noner>(float | httpx2.Timeout | None | NotGivenrqz-SyncPageCursor[BetaManagedAgentsSessionEvent])rUrGrTrGrc'List[BetaManagedAgentsDeltaType] | Omitr9rtr:rsr;rur<rvr=rwr>rxrqz2Stream[BetaManagedAgentsStreamSessionThreadEvents] __name__ __module__ __qualname____firstlineno__rr.r4rrr`rk__static_attributes__rpr0r-r$r$sU++11!15#')-$("& Q / Q !Q &Q "Q  Q :Q  <Q Q r0c \rSrSr\S Sj5r\S Sj5r\\\\SSS\S.S Sjjr \\\SSS\S.S Sjjr S r g)r%c[U5$r))AsyncEventsWithRawResponser+s r-r.AsyncEvents.with_raw_responses*$//r0c[U5$r2) AsyncEventsWithStreamingResponser+s r-r4#AsyncEvents.with_streaming_responses055r0Nr6c U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9[[[UUU U UUS .S 9[[[5S 9$) r@rArBrCc38# UHn[U5v M g7frErFrHs r-rK#AsyncEvents.list..rMrNrOrPrQrRrSrVrWrY) r\rrr]rrr^rrr"rrrr_s r-r`AsyncEvents.listsJXYcXfgh hWXaWdef f   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` !! P%#  !!>?(+'%"  2#"  r0rbc # U(d[SU<35eU(d[SU<35e0[[U5(a#SR[ SU5S/55O[ US.5EU=(d 0EnSS0U=(d 0EnUR [SUUS 9[UUUU S U0S 9[[[5S [[S 9IShvN $N7f)rerArBrCc38# UHn[U5v M g7frErFrHs r-rK%AsyncEvents.stream..grMrNrOrPrQrhrSrcrWTriN) r\rrr]rrrmrrrrr#rrns r-rkAsyncEvents.stream1s^XYcXfgh hWXaWdef f   '*hhu5Le5LOjNk/l&m".:   "  *+F`=K^\^` YY P%#  )+'%%|4 ?"#MN#    sCC CC rp)rqr)rqr)rUrGrTrGr7rrr8rsr9rtr:rsr;rur<rvr=rwr>rxrqz]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]])rUrGrTrGrcryr9rtr:rsr;rur<rvr=rwr>rxrqz7AsyncStream[BetaManagedAgentsStreamSessionThreadEvents]rzrpr0r-r%r%sW0066!15#')-$("& Q / Q !Q &Q "Q  Q :Q  AQ Q r0c\rSrSrSSjrSrg)r*icxXl[UR5Ul[UR5UlgrE)_eventsrr`rkr,eventss r-__init__EventsWithRawResponse.__init__s/ + KK  . MM  r0rr`rkNrr$rqNoner{r|r}r~rrrpr0r-r*r* r0r*c\rSrSrSSjrSrg)ricxXl[UR5Ul[UR5UlgrE)rrr`rkrs r-r#AsyncEventsWithRawResponse.__init__s/ 1 KK  4 MM  r0rNrr%rqrrrpr0r-rrrr0rc\rSrSrSSjrSrg)r3icxXl[UR5Ul[UR5UlgrE)rrr`rkrs r-r$EventsWithStreamingResponse.__init__s/ 0 KK  3 MM  r0rNrrrpr0r-r3r3rr0r3c\rSrSrSSjrSrg)ricxXl[UR5Ul[UR5UlgrE)rrr`rkrs r-r)AsyncEventsWithStreamingResponse.__init__s/ 6 KK  9 MM  r0rNrrrpr0r-rrrr0r)7 __future__rtypingrrr itertoolsrhttpx2_typesr r r r r rr_utilsrrr_compatr _resourcerr _responserrrr _streamingrr paginationrr _base_clientrrtypes.anthropic_beta_paramr )types.beta.beta_managed_agents_delta_typer!5types.beta.sessions.beta_managed_agents_session_eventr"Dtypes.beta.sessions.beta_managed_agents_stream_session_thread_eventsr#__all__r$r%r*rr3rrpr0r-rs""" MMM@@(< 0;B>Ud ] #p _p fp "p f            r0