
    _jR                       S SK Jr  S SKJrJrJrJrJr  S SKJr  S SK	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Jr  SS
KJr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K0J1r1J2r2  SSK3J4r4  SSK5J6r6  SSK7J8r8  SSK9J:r:  SSK;J<r<  SS/r= " S S\"5      r> " S S\#5      r? " S S5      r@ " S S5      rA " S S 5      rB " S! S"5      rCg)#    )annotations)AnyListUnionIterablecast)datetime)chain)LiteralN   )_legacy_response)BodyOmitQueryHeadersNotGivenSequenceNotStromit	not_given)is_givenpath_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)StreamAsyncStream)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)event_list_paramsevent_send_params)AnthropicBetaParam)BetaManagedAgentsEventParams)BetaManagedAgentsSessionEvent)"BetaManagedAgentsSendSessionEvents)$BetaManagedAgentsStreamSessionEvents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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    ]/home/rurouni/.local/lib/python3.13/site-packages/anthropic/resources/beta/sessions/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
)EventsWithStreamingResponser4   s    r6   with_streaming_responseEvents.with_streaming_response*   s     +400r9   Ncreated_at_gtcreated_at_gtecreated_at_ltcreated_at_ltelimitorderpagetypesbetasextra_headersextra_query
extra_bodytimeoutc                  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S9[        [           [        UUUU[        UUUUUUUU	S.[        R                  5      S	9[        [        [        5      S
9$ )  
List Events

Args:
  created_at_gt: Return events created after this time (exclusive).

  created_at_gte: Return events created at or after this time (inclusive).

  created_at_lt: Return events created before this time (exclusive).

  created_at_lte: Return events created at or before this time (inclusive).

  limit: Query parameter for limit

  order: Sort direction for results, ordered by created_at. Defaults to asc
      (chronological).

  page: Opaque pagination cursor from a previous response's next_page.

  types: Filter by event type. Values match the `type` field on returned events (for
      example, `user.message` or `agent.tool_use`). Omit to return all event types.

  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 anthropic-beta,c              3  8   #    U  H  n[        U5      v   M     g 7fNstr.0es     r6   	<genexpr>Events.list.<locals>.<genexpr>l        5Lec!ffe   managed-agents-2026-04-01*/v1/sessions/{session_id}/events?beta=true
session_idr@   rA   rB   rC   rD   rE   rF   rG   rI   rJ   rK   rL   queryrF   optionsmodel)
ValueErrorr   r   joinr
   r   _get_api_listr   r"   r*   r%   r   r&   EventListParamsr   r   r5   r`   r@   rA   rB   rC   rD   rE   rF   rG   rH   rI   rJ   rK   rL   s                  r6   listEvents.list3   s   h XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!FS]^ =>(+'%%)6*8)6*8!&!& $!&	 &55& 2- " 
 	
r9   rH   rI   rJ   rK   rL   c               n   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S9[        SU0[        R                  5      [        XEXgS	9[        S
9$ )}  
Send Events

Args:
  events: Events to send to 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
rO   rP   rQ   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rT   rV   s     r6   rY   Events.send.<locals>.<genexpr>   r[   r\   r]   r^   r_   eventsrI   rJ   rK   rL   bodyre   cast_to)rg   r   r   rh   r
   r   _postr   r   r'   EventSendParamsr%   r+   r5   r`   rs   rH   rI   rJ   rK   rL   s           r6   sendEvents.send   s    : XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zzFS]^ (F!35F5V5VW(+Q[ 7  
 	
r9   c          
     n   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S9[        X4XVS9[        [        [        5      S	[        [           S
9$ )S  
Stream 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
rO   rP   rQ   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rT   rV   s     r6   rY    Events.stream.<locals>.<genexpr>   r[   r\   r]   1/v1/sessions/{session_id}/events/stream?beta=truer_   rt   Tre   rw   stream
stream_cls)rg   r   r   rh   r
   r   _getr   r%   r   r   r,   r    r5   r`   rH   rI   rJ   rK   rL   s          r6   r   Events.stream   s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yyMZde(+Q[ 9 BC  

 
	
r9    )returnr3   )r   r<   )r`   rU   r@   Union[str, datetime] | OmitrA   r   rB   r   rC   r   rD   
int | OmitrE   Literal['asc', 'desc'] | OmitrF   
str | OmitrG   SequenceNotStr[str] | OmitrH   List[AnthropicBetaParam] | OmitrI   Headers | NonerJ   Query | NonerK   Body | NonerL   'float | httpx.Timeout | None | NotGivenr   z-SyncPageCursor[BetaManagedAgentsSessionEvent]r`   rU   rs   z&Iterable[BetaManagedAgentsEventParams]rH   r   rI   r   rJ   r   rK   r   rL   r   r   r+   )r`   rU   rH   r   rI   r   rJ   r   rK   r   rL   r   r   z,Stream[BetaManagedAgentsStreamSessionEvents]__name__
__module____qualname____firstlineno__r   r7   r=   r   r   rl   r{   r   __static_attributes__r   r9   r6   r-   r-      s   + + 1 1 6:6:596: /3,015 )-$("&;D%Z
Z
 3	Z

 4Z
 3Z
 4Z
 Z
 -Z
 Z
 *Z
 /Z
 &Z
  "!Z
"  #Z
$ 9%Z
& 
7'Z
B 26 )-$("&;D1
1
 7	1

 /1
 &1
 "1
  1
 91
 
,1
n 26 )-$("&;D1
1
 /	1
 &1
 "1
  1
 91
 
61
 1
r9   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SS\S.             SS	 jjrS
rg)r.      c                    [        U 5      $ r2   )AsyncEventsWithRawResponser4   s    r6   r7   AsyncEvents.with_raw_response   s     *$//r9   c                    [        U 5      $ r;   ) AsyncEventsWithStreamingResponser4   s    r6   r=   #AsyncEvents.with_streaming_response  s     055r9   Nr?   c                  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S9[        [           [        UUUU[        UUUUUUUU	S.[        R                  5      S	9[        [        [        5      S
9$ )rN   rO   rP   rQ   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rT   rV   s     r6   rY   #AsyncEvents.list.<locals>.<genexpr>C  r[   r\   r]   r^   r_   ra   rb   rd   )rg   r   r   rh   r
   r   ri   r   r#   r*   r%   r   r&   rj   r   r   rk   s                  r6   rl   AsyncEvents.list
  s   h XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!FS]^ !>?(+'%%)6*8)6*8!&!& $!&	 &55& 2- " 
 	
r9   rn   c                 #    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S9[        SU0[        R                  5      I S	h  vN [        XEXgS
9[        S9I S	h  vN $  N N7f)rp   rO   rP   rQ   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rT   rV   s     r6   rY   #AsyncEvents.send.<locals>.<genexpr>  r[   r\   r]   r^   r_   rs   Nrt   ru   )rg   r   r   rh   r
   r   rx   r   r   r'   ry   r%   r+   rz   s           r6   r{   AsyncEvents.sendf  s     : XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZFS]^,h-?ARAbAbcc(+Q[ 7   
 
 	
c
s$   B*C,C	
-CCCCc          
       #    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S9[        X4XVS9[        [        [        5      S	[        [           S
9I Sh  vN $  N7f)r~   rO   rP   rQ   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rT   rV   s     r6   rY   %AsyncEvents.stream.<locals>.<genexpr>  r[   r\   r]   r   r_   rt   Tr   N)rg   r   r   rh   r
   r   r   r   r%   r   r   r,   r!   r   s          r6   r   AsyncEvents.stream  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YYMZde(+Q[ 9 "#GH  

 

 
	
 

s   B:C<C=Cr   )r   r   )r   r   )r`   rU   r@   r   rA   r   rB   r   rC   r   rD   r   rE   r   rF   r   rG   r   rH   r   rI   r   rJ   r   rK   r   rL   r   r   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]r   )r`   rU   rH   r   rI   r   rJ   r   rK   r   rL   r   r   z1AsyncStream[BetaManagedAgentsStreamSessionEvents]r   r   r9   r6   r.   r.      s   0 0 6 6 6:6:596: /3,015 )-$("&;D%Z
Z
 3	Z

 4Z
 3Z
 4Z
 Z
 -Z
 Z
 *Z
 /Z
 &Z
  "!Z
"  #Z
$ 9%Z
& 
g'Z
B 26 )-$("&;D1
1
 7	1

 /1
 &1
 "1
  1
 91
 
,1
n 26 )-$("&;D1
1
 /	1
 &1
 "1
  1
 91
 
;1
 1
r9   c                      \ rS rSrSS jrSrg)r3   i  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        g rS   )_eventsr   to_raw_response_wrapperrl   r{   r   r5   rs   s     r6   __init__EventsWithRawResponse.__init__  sV    $<<KK
	 %<<KK
	 '>>MM
r9   r   rl   r{   r   Nrs   r-   r   Noner   r   r   r   r   r   r   r9   r6   r3   r3         
r9   r3   c                      \ rS rSrSS jrSrg)r   i  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        g rS   )r   r   async_to_raw_response_wrapperrl   r{   r   r   s     r6   r   #AsyncEventsWithRawResponse.__init__  sV    $BBKK
	 %BBKK
	 'DDMM
r9   r   Nrs   r.   r   r   r   r   r9   r6   r   r     r   r9   r   c                      \ rS rSrSS jrSrg)r<   i  c                    Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rS   )r   r   rl   r{   r   r   s     r6   r   $EventsWithStreamingResponse.__init__  sD    0KK
	 1KK
	 3MM
r9   r   Nr   r   r   r9   r6   r<   r<     r   r9   r<   c                      \ rS rSrSS jrSrg)r   i  c                    Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rS   )r   r   rl   r{   r   r   s     r6   r   )AsyncEventsWithStreamingResponse.__init__  sD    6KK
	 7KK
	 9MM
r9   r   Nr   r   r   r9   r6   r   r     r   r9   r   )D
__future__r   typingr   r   r   r   r   r	   	itertoolsr
   typing_extensionsr   httpx r   _typesr   r   r   r   r   r   r   r   _utilsr   r   r   r   r   _compatr   	_resourcer   r   	_responser   r   
_streamingr    r!   
paginationr"   r#   _base_clientr$   r%   types.beta.sessionsr&   r'   types.anthropic_beta_paramr(   4types.beta.sessions.beta_managed_agents_event_paramsr)   5types.beta.sessions.beta_managed_agents_session_eventr*   ;types.beta.sessions.beta_managed_agents_send_session_eventsr+   =types.beta.sessions.beta_managed_agents_stream_session_eventsr,   __all__r-   r.   r3   r   r<   r   r   r9   r6   <module>r      s    # 3 3   %  ! \ \ \ g g ' ; Z . : A H = a c n r]
#T
_ T
nT
" T
n
 

 

 

 
r9   