
    ÁjB                       d dl mZ d dlmZmZmZ d dlmZ d dlZddl	m
Z
 ddlmZmZmZmZmZmZmZ ddlmZmZmZmZmZ dd	lmZ dd
lmZmZ ddlmZm Z  ddl!m"Z"m#Z# ddl$m%Z%m&Z& ddl'm(Z(m)Z) ddl*m+Z+ ddl,m-Z-m.Z. ddl/m0Z0 ddl1m2Z2 ddl3m4Z4 ddgZ5 G d de      Z6 G d de      Z7 G d d      Z8 G d d      Z9 G d d      Z: G d d      Z;y)     )annotations)AnyListcast)chainN   )_legacy_response)BodyOmitQueryHeadersNotGiven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)AnthropicBetaParam)event_list_paramsevent_stream_params)BetaManagedAgentsDeltaType)BetaManagedAgentsSessionEvent)*BetaManagedAgentsStreamSessionThreadEventsEventsAsyncEventsc                      e Zd Zedd       Zed	d       Zeeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
dZeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZ	y)r'   c                    t        |       S a  
        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    W/tmp/pip-target-k_scjv0h/lib/python/anthropic/resources/beta/sessions/threads/events.pywith_raw_responsezEvents.with_raw_response   s     %T**    c                    t        |       S 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_responsezEvents.with_streaming_response)   s     +400r1   Nlimitpagebetasextra_headersextra_query
extra_bodytimeoutc                  |st        d|      |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d||      t        t           t        ||||	t        ||d	t        j                        
      t        t        t                    S )  
        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  2   K   | ]  }t        |        y wNstr.0es     r/   	<genexpr>zEvents.list.<locals>.<genexpr>Z        5Lc!f5L   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.   rR   rQ   r7   r8   r9   r:   r;   r<   r=   s
             r/   listzEvents.list2   s   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!P%#
   =>(+'%%!& $ &55 2) " 
 	
r1   event_deltasr9   r:   r;   r<   r=   c                  |st        d|      |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d||      t        ||||t        d	|it        j                        
      t        t        t              dt        t                 S )  
        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.

          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  2   K   | ]  }t        |        y wrE   rF   rH   s     r/   rK   z Events.stream.<locals>.<genexpr>   rL   rM   rN   >/v1/sessions/{session_id}/threads/{thread_id}/stream?beta=truerP   r`   rT   TrW   cast_tostream
stream_cls)rY   r   r   rZ   r   r   _getr   r    r   r#   EventStreamParamsr   r   r&   r   	r.   rR   rQ   r`   r9   r:   r;   r<   r=   s	            r/   rg   zEvents.stream{   s   N XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yyP%#
 )+'%%~|&DFYFkFkl ? HI#  
 	
r1   )returnr,   )rl   r4   )rR   rG   rQ   rG   r7   
int | Omitr8   
str | Omitr9   List[AnthropicBetaParam] | Omitr:   Headers | Noner;   Query | Noner<   Body | Noner=   'float | httpx.Timeout | None | NotGivenrl   z-SyncPageCursor[BetaManagedAgentsSessionEvent])rR   rG   rQ   rG   r`   'List[BetaManagedAgentsDeltaType] | Omitr9   ro   r:   rp   r;   rq   r<   rr   r=   rs   rl   z2Stream[BetaManagedAgentsStreamSessionThreadEvents]
__name__
__module____qualname__r   r0   r5   r   r   r^   rg    r1   r/   r'   r'      s3   + + 1 1 !15 )-$("&;DG
G
 	G

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

 >H
 /H
 &H
 "H
  H
 9H
 
<H
r1   c                      e Zd Zedd       Zed	d       Zeeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
dZeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZ	y)r(   c                    t        |       S r+   )AsyncEventsWithRawResponser-   s    r/   r0   zAsyncEvents.with_raw_response   s     *$//r1   c                    t        |       S r3   ) AsyncEventsWithStreamingResponser-   s    r/   r5   z#AsyncEvents.with_streaming_response   s     055r1   Nr6   c                  |st        d|      |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d||      t        t           t        ||||	t        ||d	t        j                        
      t        t        t                    S )r?   r@   rA   rB   rC   c              3  2   K   | ]  }t        |        y wrE   rF   rH   s     r/   rK   z#AsyncEvents.list.<locals>.<genexpr>  rL   rM   rN   rO   rP   rS   rT   rV   )rY   r   r   rZ   r   r   r[   r   r   r%   r    r   r"   r\   r   r   r]   s
             r/   r^   zAsyncEvents.list   s   B XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!P%#
 !!>?(+'%%!& $ &55 2) " 
 	
r1   r_   c                 K   |st        d|      |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d||      t        ||||t        d	|it        j                         d
{         t        t        t              dt        t                  d
{   S 7 67 w)rb   r@   rA   rB   rC   c              3  2   K   | ]  }t        |        y wrE   rF   rH   s     r/   rK   z%AsyncEvents.stream.<locals>.<genexpr>Q  rL   rM   rN   rd   rP   r`   NrT   Tre   )rY   r   r   rZ   r   r   ri   r   r    r   r#   rj   r   r   r&   r   rk   s	            r/   rg   zAsyncEvents.stream#  s.    N XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YYP%#
 )+'%1#\24G4Y4Y  ? "#MN'  
 
 	

s$   B2C/4C+51C/&C-'C/-C/)rl   r|   )rl   r~   )rR   rG   rQ   rG   r7   rm   r8   rn   r9   ro   r:   rp   r;   rq   r<   rr   r=   rs   rl   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]])rR   rG   rQ   rG   r`   rt   r9   ro   r:   rp   r;   rq   r<   rr   r=   rs   rl   z7AsyncStream[BetaManagedAgentsStreamSessionThreadEvents]ru   ry   r1   r/   r(   r(      s5   0 0 6 6 !15 )-$("&;DG
G
 	G

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

 >J
 /J
 &J
 "J
  J
 9J
 
AJ
r1   c                      e Zd ZddZy)r,   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y rE   )_eventsr	   to_raw_response_wrapperr^   rg   r.   eventss     r/   __init__zEventsWithRawResponse.__init__q  s=    $<<KK
	 '>>MM
r1   Nr   r'   rl   Nonerv   rw   rx   r   ry   r1   r/   r,   r,   p      
r1   r,   c                      e Zd ZddZy)r|   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y rE   )r   r	   async_to_raw_response_wrapperr^   rg   r   s     r/   r   z#AsyncEventsWithRawResponse.__init__}  s=    $BBKK
	 'DDMM
r1   Nr   r(   rl   r   r   ry   r1   r/   r|   r|   |  r   r1   r|   c                      e Zd ZddZy)r4   c                z    || _         t        |j                        | _        t        |j                        | _        y rE   )r   r   r^   rg   r   s     r/   r   z$EventsWithStreamingResponse.__init__  s1    0KK
	 3MM
r1   Nr   r   ry   r1   r/   r4   r4     r   r1   r4   c                      e Zd ZddZy)r~   c                z    || _         t        |j                        | _        t        |j                        | _        y rE   )r   r   r^   rg   r   s     r/   r   z)AsyncEventsWithStreamingResponse.__init__  s1    6KK
	 9MM
r1   Nr   r   ry   r1   r/   r~   r~     r   r1   r~   )<
__future__r   typingr   r   r   	itertoolsr   httpx r	   _typesr
   r   r   r   r   r   r   _utilsr   r   r   r   r   _compatr   	_resourcer   r   	_responser   r   
_streamingr   r   
paginationr   r   _base_clientr   r    types.anthropic_beta_paramr!   types.beta.sessions.threadsr"   r#   )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,   r|   r4   r~   ry   r1   r/   <module>r      s    # " "   " M M M h h ( < [ / ; B > S U d ]
#e
_ e
Pg
" g
T	
 	
	
 	
	
 	
	
 	
r1   