§
    ÜŽ’j+D  ã                  óÊ  — 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;dS ) é    )Ú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                  óp   — 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	dS )$r'   ÚreturnÚEventsWithRawResponsec                ó    — 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
        )r+   ©Úselfs    ú^C:\Projects\DSCons\.venv\Lib\site-packages\anthropic\resources\beta\sessions\threads\events.pyÚwith_raw_responsezEvents.with_raw_response   s   € õ % TÑ*Ô*Ð*ó    ÚEventsWithStreamingResponsec                ó    — 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
        )r3   r.   s    r0   Úwith_streaming_responsezEvents.with_streaming_response)   s   € õ +¨4Ñ0Ô0Ð0r2   N©ÚlimitÚpageÚbetasÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutÚ	thread_idÚstrÚ
session_idr8   ú
int | Omitr9   ú
str | Omitr:   úList[AnthropicBetaParam] | Omitr;   úHeaders | Noner<   úQuery | Noner=   úBody | Noner>   ú'float | httpx.Timeout | None | NotGivenú-SyncPageCursor[BetaManagedAgentsSessionEvent]c               ó  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      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  ó4   K  — | ]}t          |¦  «        V — Œd S ©N©r@   ©Ú.0Úes     r0   ú	<genexpr>zEvents.list.<locals>.<genexpr>Z   ó(   è è € Ð5LÐ5LÀµc¸!±f´fÐ5LÐ5LÐ5LÐ5LÐ5LÐ5Lr2   úmanaged-agents-2026-04-01ú>/v1/sessions/{session_id}/threads/{thread_id}/events?beta=true©rA   r?   ©r8   r9   ©r;   r<   r=   r>   Úquery©r9   ÚoptionsÚmodel)Ú
ValueErrorr   r   Újoinr   r   Ú_get_api_listr   r   r%   r    r   r"   ÚEventListParamsr   r   ©
r/   r?   rA   r8   r9   r:   r;   r<   r=   r>   s
             r0   ÚlistzEvents.list2   si  € ðB ð 	iÝÐgÐYcÐgÐgÑhÔhÐhØð 	gÝÐeÐXaÐeÐeÑfÔfÐfð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝØPØ%Ø#ðñ ô õ
  Õ =Ô>Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ &Ô5ñô ðñ ô õ ÝÕ2ñô ð) "ñ 
ô 
ð 	
r2   ©Úevent_deltasr:   r;   r<   r=   r>   rh   ú'List[BetaManagedAgentsDeltaType] | Omitú2Stream[BetaManagedAgentsStreamSessionThreadEvents]c               ó  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      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
        rL   rM   rN   rO   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rQ   rR   rS   s     r0   rV   z Events.stream.<locals>.<genexpr>©   rW   r2   rX   ú>/v1/sessions/{session_id}/threads/{thread_id}/stream?beta=truerZ   rh   r\   T©r_   Úcast_toÚstreamÚ
stream_cls)ra   r   r   rb   r   r   Ú_getr   r    r   r#   ÚEventStreamParamsr   r   r&   r   ©	r/   r?   rA   rh   r:   r;   r<   r=   r>   s	            r0   rq   zEvents.stream{   s]  € ðN ð 	iÝÐgÐYcÐgÐgÑhÔhÐhØð 	gÝÐeÐXaÐeÐeÑfÔfÐfð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ�yŠyÝØPØ%Ø#ðñ ô õ
 )Ø+Ø'Ø%ØÝ% ~°|Ð&DÕFYÔFkÑlÔlðñ ô õ ÝÕ?ñô ð ÝÕHÔIð# ñ 
ô 
ð 	
r2   )r*   r+   )r*   r3   )r?   r@   rA   r@   r8   rB   r9   rC   r:   rD   r;   rE   r<   rF   r=   rG   r>   rH   r*   rI   )r?   r@   rA   r@   rh   ri   r:   rD   r;   rE   r<   rF   r=   rG   r>   rH   r*   rj   ©
Ú__name__Ú
__module__Ú__qualname__r   r1   r6   r   r   rf   rq   © r2   r0   r'   r'      sÎ   € € € € € Øð+ð +ð +ñ „_ð+ð ð1ð 1ð 1ñ „_ð1ð !ØØ15ð )-Ø$(Ø"&Ø;DðG
ð G
ð G
ð G
ð G
ð G
ð\ AEØ15ð )-Ø$(Ø"&Ø;DðH
ð H
ð H
ð H
ð H
ð H
ð H
ð H
r2   c                  óp   — 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	dS )$r(   r*   ÚAsyncEventsWithRawResponsec                ó    — t          | ¦  «        S r-   )r|   r.   s    r0   r1   zAsyncEvents.with_raw_responseÇ   s   € õ *¨$Ñ/Ô/Ð/r2   Ú AsyncEventsWithStreamingResponsec                ó    — t          | ¦  «        S r5   )r~   r.   s    r0   r6   z#AsyncEvents.with_streaming_responseÑ   s   € õ 0°Ñ5Ô5Ð5r2   Nr7   r?   r@   rA   r8   rB   r9   rC   r:   rD   r;   rE   r<   rF   r=   rG   r>   rH   ú]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]c               ó  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          t                   t          ||||	t          ||d	œt          j        ¦  «        ¬
¦  «        t          t          t          ¦  «        ¬¦  «        S )rK   rL   rM   rN   rO   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rQ   rR   rS   s     r0   rV   z#AsyncEvents.list.<locals>.<genexpr>  rW   r2   rX   rY   rZ   r[   r\   r^   )ra   r   r   rb   r   r   rc   r   r   r%   r    r   r"   rd   r   r   re   s
             r0   rf   zAsyncEvents.listÚ   si  € ðB ð 	iÝÐgÐYcÐgÐgÑhÔhÐhØð 	gÝÐeÐXaÐeÐeÑfÔfÐfð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝØPØ%Ø#ðñ ô õ
 !Õ!>Ô?Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ &Ô5ñô ðñ ô õ ÝÕ2ñô ð) "ñ 
ô 
ð 	
r2   rg   rh   ri   ú7AsyncStream[BetaManagedAgentsStreamSessionThreadEvents]c             ƒ  ó,  K  — |st          d|›�¦  «        ‚|st          d|›�¦  «        ‚i t          dt          |¦  «        r.d                     t	          d„ |D ¦   «         dg¦  «        ¦  «        nt
          i¦  «        ¥|pi ¥}ddi|pi ¥}|                      t          d||¬¦  «        t          ||||t          d	|it          j        ¦  «        ƒ d
{V —†¬¦  «        t          t          t          ¦  «        dt          t                   ¬¦  «        ƒ d
{V —†S )rl   rL   rM   rN   rO   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S rQ   rR   rS   s     r0   rV   z%AsyncEvents.stream.<locals>.<genexpr>Q  rW   r2   rX   rn   rZ   rh   Nr\   Tro   )ra   r   r   rb   r   r   rs   r   r    r   r#   rt   r   r   r&   r   ru   s	            r0   rq   zAsyncEvents.stream#  s¢  è è € ðN ð 	iÝÐgÐYcÐgÐgÑhÔhÐhØð 	gÝÐeÐXaÐeÐeÑfÔfÐfð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ—Y’YÝØPØ%Ø#ðñ ô õ
 )Ø+Ø'Ø%ØÝ1Ø# \Ð2Õ4GÔ4Yñô ð ð ð ð ð ð ðñ ô õ ÝÕ?ñô ð Ý"Õ#MÔNð' ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r2   )r*   r|   )r*   r~   )r?   r@   rA   r@   r8   rB   r9   rC   r:   rD   r;   rE   r<   rF   r=   rG   r>   rH   r*   r€   )r?   r@   rA   r@   rh   ri   r:   rD   r;   rE   r<   rF   r=   rG   r>   rH   r*   rƒ   rv   rz   r2   r0   r(   r(   Æ   sÎ   € € € € € Øð0ð 0ð 0ñ „_ð0ð ð6ð 6ð 6ñ „_ð6ð !ØØ15ð )-Ø$(Ø"&Ø;DðG
ð G
ð G
ð G
ð G
ð G
ð\ AEØ15ð )-Ø$(Ø"&Ø;DðJ
ð J
ð J
ð J
ð J
ð J
ð J
ð J
r2   c                  ó   — e Zd Zdd„ZdS )r+   Úeventsr'   r*   ÚNonec                óŒ   — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        d S rQ   )Ú_eventsr	   Úto_raw_response_wrapperrf   rq   ©r/   r‡   s     r0   Ú__init__zEventsWithRawResponse.__init__q  sA   € ØˆŒå$Ô<ØŒKñ
ô 
ˆŒ	õ 'Ô>ØŒMñ
ô 
ˆŒˆˆr2   N©r‡   r'   r*   rˆ   ©rw   rx   ry   r�   rz   r2   r0   r+   r+   p  ó(   € € € € € ð
ð 
ð 
ð 
ð 
ð 
r2   r+   c                  ó   — e Zd Zdd„ZdS )r|   r‡   r(   r*   rˆ   c                óŒ   — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        d S rQ   )rŠ   r	   Úasync_to_raw_response_wrapperrf   rq   rŒ   s     r0   r�   z#AsyncEventsWithRawResponse.__init__}  sA   € ØˆŒå$ÔBØŒKñ
ô 
ˆŒ	õ 'ÔDØŒMñ
ô 
ˆŒˆˆr2   N©r‡   r(   r*   rˆ   r�   rz   r2   r0   r|   r|   |  r�   r2   r|   c                  ó   — e Zd Zdd„ZdS )r3   r‡   r'   r*   rˆ   c                óx   — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        d S rQ   )rŠ   r   rf   rq   rŒ   s     r0   r�   z$EventsWithStreamingResponse.__init__‰  s;   € ØˆŒå0ØŒKñ
ô 
ˆŒ	õ 3ØŒMñ
ô 
ˆŒˆˆr2   NrŽ   r�   rz   r2   r0   r3   r3   ˆ  r�   r2   r3   c                  ó   — e Zd Zdd„ZdS )r~   r‡   r(   r*   rˆ   c                óx   — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        d S rQ   )rŠ   r   rf   rq   rŒ   s     r0   r�   z)AsyncEventsWithStreamingResponse.__init__•  s;   € ØˆŒå6ØŒKñ
ô 
ˆŒ	õ 9ØŒMñ
ô 
ˆŒˆˆr2   Nr”   r�   rz   r2   r0   r~   r~   ”  r�   r2   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|   r3   r~   rz   r2   r0   ú<module>r¬      s×  ðð #Ð "Ð "Ð "Ð "Ð "à "Ð "Ð "Ð "Ð "Ð "Ð "Ð "Ð "Ð "Ø Ð Ð Ð Ð Ð à €€€à "Ð "Ð "Ð "Ð "Ð "Ø MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MØ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hÐ hØ (Ð (Ð (Ð (Ð (Ð (Ø <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ø [Ð [Ð [Ð [Ð [Ð [Ð [Ð [Ø /Ð /Ð /Ð /Ð /Ð /Ð /Ð /Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø BÐ BÐ BÐ BÐ BÐ BÐ BÐ BØ >Ð >Ð >Ð >Ð >Ð >Ø SÐ SÐ SÐ SÐ SÐ SÐ SÐ SØ UÐ UÐ UÐ UÐ UÐ UØ dÐ dÐ dÐ dÐ dÐ dðð ð ð ð ð ð �]Ð
#€ðe
ð e
ð e
ð e
ð e
ˆ_ñ e
ô e
ð e
ðPg
ð g
ð g
ð g
ð g
Ð"ñ g
ô g
ð g
ðT	
ð 	
ð 	
ð 	
ð 	
ñ 	
ô 	
ð 	
ð	
ð 	
ð 	
ð 	
ð 	
ñ 	
ô 	
ð 	
ð	
ð 	
ð 	
ð 	
ð 	
ñ 	
ô 	
ð 	
ð	
ð 	
ð 	
ð 	
ð 	
ñ 	
ô 	
ð 	
ð 	
ð 	
r2   