+
    ~j|9                       ^ RI Ht ^ RIHtHtHt ^ RIHt ^ RIt^RI	H
t
 ^RIHtHtHtHtHtHtHt ^RIHtHtHtHt ^RIHt ^R	IHtHt ^R
IHtHt ^RI H!t!H"t" ^RI#H$t$H%t% ^RI&H't'H(t( ^RI)H*t* ^RI+H,t, ^RI-H.t. ^RI/H0t0 RR.t1 ! R R]4      t2 ! R R]4      t3 ! R R4      t4 ! R R4      t5 ! R R4      t6 ! R R4      t7R# )    )annotations)AnyListcast)chainN)_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)is_givenpath_templatemaybe_transformstrip_not_given)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)StreamAsyncStream)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)AnthropicBetaParam)event_list_params)BetaManagedAgentsSessionEvent)*BetaManagedAgentsStreamSessionThreadEventsEventsAsyncEventsc                      ] tR t^t]R R l4       t]R R l4       tR]R]R]RR	R
R	RR	R]/R R llt	R]RR	R
R	RR	R]/R R llt
RtR	# )r#   c                   V ^8  d   QhRR/# )   returnEventsWithRawResponse )formats   "څ/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anthropic/resources/beta/sessions/threads/events.py__annotate__Events.__annotate__   s     + +#8 +    c                    \        V 4      # 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
)r)   selfs   &r,   with_raw_responseEvents.with_raw_response   s     %T**r/   c                   V ^8  d   QhRR/# )r'   r(   EventsWithStreamingResponser*   )r+   s   "r,   r-   r.   )   s     1 1)D 1r/   c                    \        V 4      # 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
)r7   r2   s   &r,   with_streaming_responseEvents.with_streaming_response(   s     +400r/   limitpagebetasextra_headersNextra_query
extra_bodytimeoutc               @    V ^8  d   QhRRRRRRRRRR	R
RRRRRRRRR/
# )r'   	thread_idstr
session_idr<   
int | Omitr=   
str | Omitr>   List[AnthropicBetaParam] | Omitr?   Headers | Noner@   Query | NonerA   Body | NonerB   'float | httpx.Timeout | None | NotGivenr(   z-SyncPageCursor[BetaManagedAgentsSessionEvent]r*   )r+   s   "r,   r-   r.   1   sz     G
 G
G
 	G

 G
 G
 /G
 &G
 "G
  G
 9G
 
7G
r/   c                  V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        \        ,          \        VVVV	\        R	VR
V/\        P                  4      R7      \        \        \        4      R7      # )  
List Session Thread Events

Args:
  limit: Query parameter for limit

  page: Query parameter for page

  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 8Expected a non-empty value for `thread_id` but received anthropic-beta,c              3  8   "   T F  p\        V4      x  K  	  R # 5iNrE   .0es   & r,   	<genexpr>Events.list.<locals>.<genexpr>Y        5Lec!ffe   managed-agents-2026-04-01>/v1/sessions/{session_id}/threads/{thread_id}/events?beta=truerF   rD   r<   r=   r?   r@   rA   rB   queryr=   optionsmodel)
ValueErrorr   r   joinr   r   _get_api_listr   r   r!   r   r   r    EventListParamsr   r   
r3   rD   rF   r<   r=   r>   r?   r@   rA   rB   s
   &&$$$$$$$$r,   listEvents.list1   s#   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`!!P%#
   =>(+'%% &55 2) " 
 	
r/   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# )r'   rD   rE   rF   r>   rI   r?   rJ   r@   rK   rA   rL   rB   rM   r(   z2Stream[BetaManagedAgentsStreamSessionThreadEvents]r*   )r+   s   "r,   r-   r.   z   sZ     8
 8
8
 	8

 /8
 &8
 "8
  8
 98
 
<8
r/   c          
        V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        WEWgR	7      \        \        \        4      R
\        \        ,          R7      # )b  
Stream Session Thread Events

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
rP   rQ   rR   rS   c              3  8   "   T F  p\        V4      x  K  	  R # 5irU   rV   rW   s   & r,   rZ    Events.stream.<locals>.<genexpr>   r\   r]   r^   >/v1/sessions/{session_id}/threads/{thread_id}/stream?beta=truer`   r?   r@   rA   rB   Trd   cast_tostream
stream_cls)rf   r   r   rg   r   r   _getr   r   r   r   r"   r   r3   rD   rF   r>   r?   r@   rA   rB   s   &&$$$$$$r,   rv   Events.streamz   s    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`yyP%#
 )+Q[ ? HI  
 	
r/   r*   __name__
__module____qualname____firstlineno__r   r4   r:   r   r   rk   rv   __static_attributes__r*   r/   r,   r#   r#      s    + + 1 1G

 !G
  G
 26G
 )-G
 %)G
 #'G
 <EG
R8

 268
 )-8
 %)8
 #'8
 <E8
 8
r/   c                      ] tR t^t]R R l4       t]R R l4       tR]R]R]RR	R
R	RR	R]/R R llt	R]RR	R
R	RR	R]/R R llt
RtR	# )r$   c                   V ^8  d   QhRR/# )r'   r(   AsyncEventsWithRawResponser*   )r+   s   "r,   r-   AsyncEvents.__annotate__   s     0 0#= 0r/   c                    \        V 4      # r1   )r   r2   s   &r,   r4   AsyncEvents.with_raw_response   s     *$//r/   c                   V ^8  d   QhRR/# )r'   r(    AsyncEventsWithStreamingResponser*   )r+   s   "r,   r-   r      s     6 6)I 6r/   c                    \        V 4      # r9   )r   r2   s   &r,   r:   #AsyncEvents.with_streaming_response   s     055r/   r<   r=   r>   r?   Nr@   rA   rB   c               @    V ^8  d   QhRRRRRRRRRR	R
RRRRRRRRR/
# )r'   rD   rE   rF   r<   rG   r=   rH   r>   rI   r?   rJ   r@   rK   rA   rL   rB   rM   r(   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]r*   )r+   s   "r,   r-   r      s{     G
 G
G
 	G

 G
 G
 /G
 &G
 "G
  G
 9G
 
gG
r/   c                  V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        \        ,          \        VVVV	\        R	VR
V/\        P                  4      R7      \        \        \        4      R7      # )rO   rP   rQ   rR   rS   c              3  8   "   T F  p\        V4      x  K  	  R # 5irU   rV   rW   s   & r,   rZ   #AsyncEvents.list.<locals>.<genexpr>   r\   r]   r^   r_   r`   r<   r=   ra   rc   )rf   r   r   rg   r   r   rh   r   r   r!   r   r   r    ri   r   r   rj   s
   &&$$$$$$$$r,   rk   AsyncEvents.list   s#   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`!!P%#
 !!>?(+'%% &55 2) " 
 	
r/   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# )r'   rD   rE   rF   r>   rI   r?   rJ   r@   rK   rA   rL   rB   rM   r(   z7AsyncStream[BetaManagedAgentsStreamSessionThreadEvents]r*   )r+   s   "r,   r-   r     s[     8
 8
8
 	8

 /8
 &8
 "8
  8
 98
 
A8
r/   c          
       "   V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        WEWgR	7      \        \        \        4      R
\        \        ,          R7      G Rj  xL
 #  L5i)ro   rP   rQ   rR   rS   c              3  8   "   T F  p\        V4      x  K  	  R # 5irU   rV   rW   s   & r,   rZ   %AsyncEvents.stream.<locals>.<genexpr>4  r\   r]   r^   rr   r`   rs   Trt   N)rf   r   r   rg   r   r   rx   r   r   r   r   r"   r   ry   s   &&$$$$$$r,   rv   AsyncEvents.stream  s
    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`YYP%#
 )+Q[ ? "#MN  
 
 	
 
s$   C,AC, C,AC,%C*&C,r*   r{   r*   r/   r,   r$   r$      s    0 0 6 6G

 !G
  G
 26G
 )-G
 %)G
 #'G
 <EG
R8

 268
 )-8
 %)8
 #'8
 <E8
 8
r/   c                  "    ] tR tRtR R ltRtR# )r)   iM  c                    V ^8  d   QhRRRR/# r'   eventsr#   r(   Noner*   )r+   s   "r,   r-   "EventsWithRawResponse.__annotate__N       
 
v 
$ 
r/   c                	    Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # rU   )_eventsr   to_raw_response_wrapperrk   rv   r3   r   s   &&r,   __init__EventsWithRawResponse.__init__N  s;    $<<KK
	 '>>MM
r/   r   rk   rv   Nr|   r}   r~   r   r   r   r*   r/   r,   r)   r)   M      
 
r/   r)   c                  "    ] tR tRtR R ltRtR# )r   iY  c                    V ^8  d   QhRRRR/# r'   r   r$   r(   r   r*   )r+   s   "r,   r-   'AsyncEventsWithRawResponse.__annotate__Z       
 
{ 
t 
r/   c                	    Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        R # rU   )r   r   async_to_raw_response_wrapperrk   rv   r   s   &&r,   r   #AsyncEventsWithRawResponse.__init__Z  s;    $BBKK
	 'DDMM
r/   r   Nr   r*   r/   r,   r   r   Y  r   r/   r   c                  "    ] tR tRtR R ltRtR# )r7   ie  c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   (EventsWithStreamingResponse.__annotate__f  r   r/   c                	z    Wn         \        VP                  4      V n        \        VP                  4      V n        R # rU   )r   r   rk   rv   r   s   &&r,   r   $EventsWithStreamingResponse.__init__f  s/    0KK
	 3MM
r/   r   Nr   r*   r/   r,   r7   r7   e  r   r/   r7   c                  "    ] tR tRtR R ltRtR# )r   iq  c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   -AsyncEventsWithStreamingResponse.__annotate__r  r   r/   c                	z    Wn         \        VP                  4      V n        \        VP                  4      V n        R # rU   )r   r   rk   rv   r   s   &&r,   r   )AsyncEventsWithStreamingResponse.__init__r  s/    6KK
	 9MM
r/   r   Nr   r*   r/   r,   r   r   q  r   r/   r   )8
__future__r   typingr   r   r   	itertoolsr   httpx r   _typesr	   r
   r   r   r   r   r   _utilsr   r   r   r   _compatr   	_resourcer   r   	_responser   r   
_streamingr   r   
paginationr   r   _base_clientr   r   types.anthropic_beta_paramr   types.beta.sessions.threadsr    5types.beta.sessions.beta_managed_agents_session_eventr!   Dtypes.beta.sessions.beta_managed_agents_stream_session_thread_eventsr"   __all__r#   r$   r)   r   r7   r   r*   r/   r,   <module>r      s    # " "   " M M M Q Q ( < [ / ; B > > d ]
#U
_ U
pU
" U
p	
 	
	
 	
	
 	
	
 	
r/   