
    _j|9                       S SK Jr  S SKJrJrJr  S SKJr  S SKrSSK	J
r
  SSKJrJrJrJrJrJrJr  SSKJrJrJrJr  SS	KJr  SS
KJrJr  SSKJrJr  SSK J!r!J"r"  SSK#J$r$J%r%  SSK&J'r'J(r(  SSK)J*r*  SSK+J,r,  SSK-J.r.  SSK/J0r0  SS/r1 " S S\5      r2 " S S\5      r3 " S S5      r4 " S S5      r5 " S S5      r6 " S S5      r7g)    )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                      \ rS rSr\S
S j5       r\SS j5       r\\\SSS\S.                   SS jjr	\SSS\S.               SS jjr
S	rg)r$      c                    [        U 5      $ 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
)EventsWithRawResponseselfs    e/home/rurouni/.local/lib/python3.13/site-packages/anthropic/resources/beta/sessions/threads/events.pywith_raw_responseEvents.with_raw_response   s     %T**    c                    [        U 5      $ 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_responseEvents.with_streaming_response(   s     +400r0   Nlimitpagebetasextra_headersextra_query
extra_bodytimeoutc                  U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS9[        [           [        UUUU	[        UUS	.[        R                  5      S
9[        [        [        5      S9$ )  
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   #    U  H  n[        U5      v   M     g 7fNstr.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
session_id	thread_idr7   r8   r:   r;   r<   r=   queryr8   optionsmodel)
ValueErrorr   r   joinr   r   _get_api_listr   r   r"   r   r   r!   EventListParamsr   r   
r,   rS   rR   r7   r8   r9   r:   r;   r<   r=   s
             r-   listEvents.list1   s   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!P%#
   =>(+'%%!& $ &55 2) " 
 	
r0   r9   r:   r;   r<   r=   c          
        U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS9[        XEXgS	9[        [        [        5      S
[        [           S9$ )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
r@   rA   rB   rC   c              3  8   #    U  H  n[        U5      v   M     g 7frE   rF   rH   s     r-   rK    Events.stream.<locals>.<genexpr>   rM   rN   rO   >/v1/sessions/{session_id}/threads/{thread_id}/stream?beta=truerQ   r:   r;   r<   r=   TrX   cast_tostream
stream_cls)rZ   r   r   r[   r   r   _getr   r   r   r   r#   r   r,   rS   rR   r9   r:   r;   r<   r=   s           r-   rj   Events.streamz   s    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yyP%#
 )+Q[ ? HI  
 	
r0    )returnr*   )rp   r3   )rS   rG   rR   rG   r7   
int | Omitr8   
str | Omitr9   List[AnthropicBetaParam] | Omitr:   Headers | Noner;   Query | Noner<   Body | Noner=   'float | httpx.Timeout | None | NotGivenrp   z-SyncPageCursor[BetaManagedAgentsSessionEvent])rS   rG   rR   rG   r9   rs   r:   rt   r;   ru   r<   rv   r=   rw   rp   z2Stream[BetaManagedAgentsStreamSessionThreadEvents]__name__
__module____qualname____firstlineno__r   r.   r4   r   r   r_   rj   __static_attributes__ro   r0   r-   r$   r$      s   + + 1 1 !15 )-$("&;DG
G
 	G

 G
 G
 /G
 &G
 "G
  G
 9G
 
7G
\ 26 )-$("&;D8
8
 	8

 /8
 &8
 "8
  8
 98
 
<8
 8
r0   c                      \ rS rSr\S
S j5       r\SS j5       r\\\SSS\S.                   SS jjr	\SSS\S.               SS jjr
S	rg)r%      c                    [        U 5      $ r)   )AsyncEventsWithRawResponser+   s    r-   r.   AsyncEvents.with_raw_response   s     *$//r0   c                    [        U 5      $ r2   ) AsyncEventsWithStreamingResponser+   s    r-   r4   #AsyncEvents.with_streaming_response   s     055r0   Nr6   c                  U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS9[        [           [        UUUU	[        UUS	.[        R                  5      S
9[        [        [        5      S9$ )r?   r@   rA   rB   rC   c              3  8   #    U  H  n[        U5      v   M     g 7frE   rF   rH   s     r-   rK   #AsyncEvents.list.<locals>.<genexpr>   rM   rN   rO   rP   rQ   rT   rU   rW   )rZ   r   r   r[   r   r   r\   r   r   r"   r   r   r!   r]   r   r   r^   s
             r-   r_   AsyncEvents.list   s   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!P%#
 !!>?(+'%%!& $ &55 2) " 
 	
r0   ra   c          
       #    U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS9[        XEXgS	9[        [        [        5      S
[        [           S9I Sh  vN $  N7f)rc   r@   rA   rB   rC   c              3  8   #    U  H  n[        U5      v   M     g 7frE   rF   rH   s     r-   rK   %AsyncEvents.stream.<locals>.<genexpr>4  rM   rN   rO   rf   rQ   rg   Trh   N)rZ   r   r   r[   r   r   rl   r   r   r   r   r#   r   rm   s           r-   rj   AsyncEvents.stream  s    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YYP%#
 )+Q[ ? "#MN  
 
 	
 
s   CCCCro   )rp   r   )rp   r   )rS   rG   rR   rG   r7   rq   r8   rr   r9   rs   r:   rt   r;   ru   r<   rv   r=   rw   rp   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]])rS   rG   rR   rG   r9   rs   r:   rt   r;   ru   r<   rv   r=   rw   rp   z7AsyncStream[BetaManagedAgentsStreamSessionThreadEvents]rx   ro   r0   r-   r%   r%      s!   0 0 6 6 !15 )-$("&;DG
G
 	G

 G
 G
 /G
 &G
 "G
  G
 9G
 
gG
\ 26 )-$("&;D8
8
 	8

 /8
 &8
 "8
  8
 98
 
A8
 8
r0   c                      \ rS rSrSS jrSrg)r*   iM  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g rE   )_eventsr	   to_raw_response_wrapperr_   rj   r,   eventss     r-   __init__EventsWithRawResponse.__init__N  s;    $<<KK
	 '>>MM
r0   r   r_   rj   Nr   r$   rp   Nonery   rz   r{   r|   r   r}   ro   r0   r-   r*   r*   M      
r0   r*   c                      \ rS rSrSS jrSrg)r   iY  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g rE   )r   r	   async_to_raw_response_wrapperr_   rj   r   s     r-   r   #AsyncEventsWithRawResponse.__init__Z  s;    $BBKK
	 'DDMM
r0   r   Nr   r%   rp   r   r   ro   r0   r-   r   r   Y  r   r0   r   c                      \ rS rSrSS jrSrg)r3   ie  c                x    Xl         [        UR                  5      U l        [        UR                  5      U l        g rE   )r   r   r_   rj   r   s     r-   r   $EventsWithStreamingResponse.__init__f  s/    0KK
	 3MM
r0   r   Nr   r   ro   r0   r-   r3   r3   e  r   r0   r3   c                      \ rS rSrSS jrSrg)r   iq  c                x    Xl         [        UR                  5      U l        [        UR                  5      U l        g rE   )r   r   r_   rj   r   s     r-   r   )AsyncEventsWithStreamingResponse.__init__r  s/    6KK
	 9MM
r0   r   Nr   r   ro   r0   r-   r   r   q  r   r0   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   r3   r   ro   r0   r-   <module>r      s    # " "   " M M M Q Q ( < [ / ; B > > d ]
#U
_ U
pU
" U
p	
 	
	
 	
	
 	
	
 	
r0   