Ë
    ÂjÎJ  ã                  óŒ  — d dl mZ d dl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 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 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, ddl-m.Z. ddl/m0Z0 ddgZ1 G d„ de «      Z2 G d„ de!«      Z3 G d„ d«      Z4 G d„ d«      Z5 G d„ d«      Z6 G d„ d«      Z7y)é    )Úannotations)ÚList)ÚchainNé   )Ú_legacy_responseé   )ÚEventsÚAsyncEventsÚEventsWithRawResponseÚAsyncEventsWithRawResponseÚEventsWithStreamingResponseÚ AsyncEventsWithStreamingResponse)Ú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)ÚSyncPageCursorÚAsyncPageCursor)ÚAsyncPaginatorÚmake_request_options)Úthread_list_params)ÚAnthropicBetaParam)ÚBetaManagedAgentsSessionThreadÚThreadsÚAsyncThreadsc                  óæ   — e Zd Zed
d„«       Zedd„«       Zedd„«       Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z	eeedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z
edddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd	„Zy)r&   c                ó,   — t        | j                  «      S ©N)r	   Ú_client©Úselfs    úd/var/www/html/venv/lib/python3.12/site-packages/anthropic/resources/beta/sessions/threads/threads.pyÚeventszThreads.events"   s   € ä�d—l‘lÓ#Ð#ó    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
        )ÚThreadsWithRawResponser,   s    r.   Úwith_raw_responsezThreads.with_raw_response&   s   € ô & dÓ+Ð+r0   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
        )ÚThreadsWithStreamingResponser,   s    r.   Úwith_streaming_responsezThreads.with_streaming_response0   s   € ô ,¨DÓ1Ð1r0   N©ÚbetasÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc          
     óF  — |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        ¬
«      S )á˜  
        Get Session Thread

        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
        ú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r*   ©Ústr©Ú.0Úes     r.   Ú	<genexpr>z#Threads.retrieve.<locals>.<genexpr>[   ó   è ø€ Ð5LÁeÀ´c¸!·fÁeùó   ‚úmanaged-agents-2026-04-01ú7/v1/sessions/{session_id}/threads/{thread_id}?beta=true©Ú
session_idÚ	thread_id©r;   r<   r=   r>   ©ÚoptionsÚcast_to©
Ú
ValueErrorr   r   Újoinr   r   Ú_getr   r"   r%   ©r-   rR   rQ   r:   r;   r<   r=   r>   s           r.   ÚretrievezThreads.retrieve9   sá   € ñ6 ÜÐXÐYcÐXfÐgÓhÐhÙÜÐWÐXaÐWdÐeÓfÐfð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ�y‰yÜØIÐV`Ðluôô )Ø+¸ÐQ[Ðelôô 3ð ó 
ð 	
r0   ©ÚlimitÚpager:   r;   r<   r=   r>   c               ót  — |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        ¬
«      S )á6  List Session Threads

        Args:
          limit: Maximum results per page.

        Defaults to 1000.

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

          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
        rA   rC   rD   c              3  ó2   K  — | ]  }t        |«      –— Œ y ­wr*   rF   rH   s     r.   rK   zThreads.list.<locals>.<genexpr>“   rL   rM   rN   ú+/v1/sessions/{session_id}/threads?beta=true©rQ   ©r^   r_   ©r;   r<   r=   r>   Úquery©r_   rU   Úmodel)rX   r   r   rY   r   r   Ú_get_api_listr   r   r%   r"   r   r#   ÚThreadListParams©	r-   rQ   r^   r_   r:   r;   r<   r=   r>   s	            r.   ÚlistzThreads.listm   sí   € ñB ÜÐXÐYcÐXfÐgÓhÐhð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ×!Ñ!ÜÐGÐT^Ô_ÜÔ >Ñ?Ü(Ø+Ø'Ø%ØÜ%à!&Ø $ñô '×7Ñ7óôô 1ð! "ó 
ð 	
r0   c          
     óF  — |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        ¬
«      S )áœ  
        Archive Session Thread

        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
        rA   rB   rC   rD   c              3  ó2   K  — | ]  }t        |«      –— Œ y ­wr*   rF   rH   s     r.   rK   z"Threads.archive.<locals>.<genexpr>Ð   rL   rM   rN   ú?/v1/sessions/{session_id}/threads/{thread_id}/archive?beta=truerP   rS   rT   ©
rX   r   r   rY   r   r   Ú_postr   r"   r%   r[   s           r.   ÚarchivezThreads.archive®   sá   € ñ6 ÜÐXÐYcÐXfÐgÓhÐhÙÜÐWÐXaÐWdÐeÓfÐfð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ�z‰zÜØQØ%Ø#ôô
 )Ø+¸ÐQ[Ðelôô 3ð ó 

ð 
	
r0   )Úreturnr	   )ru   r3   )ru   r7   ©rR   rG   rQ   rG   r:   úList[AnthropicBetaParam] | Omitr;   úHeaders | Noner<   úQuery | Noner=   úBody | Noner>   ú'float | httpx.Timeout | None | NotGivenru   r%   )rQ   rG   r^   ú
int | Omitr_   ú
str | Omitr:   rw   r;   rx   r<   ry   r=   rz   r>   r{   ru   z.SyncPageCursor[BetaManagedAgentsSessionThread]©Ú__name__Ú
__module__Ú__qualname__r   r/   r4   r8   r   r   r\   rm   rt   © r0   r.   r&   r&   !   s€  „ Øò$ó ð$ð ò,ó ð,ð ò2ó ð2ð 26ð )-Ø$(Ø"&Ø;Dñ2
àð2
ð ð	2
ð
 /ð2
ð &ð2
ð "ð2
ð  ð2
ð 9ð2
ð 
(ó2
ðp !ØØ15ð )-Ø$(Ø"&Ø;Dñ?
àð?
ð ð	?
ð
 ð?
ð /ð?
ð &ð?
ð "ð?
ð  ð?
ð 9ð?
ð 
8ó?
ðL 26ð )-Ø$(Ø"&Ø;Dñ4
àð4
ð ð	4
ð
 /ð4
ð &ð4
ð "ð4
ð  ð4
ð 9ð4
ð 
(ô4
r0   c                  óæ   — e Zd Zed
d„«       Zedd„«       Zedd„«       Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z	eeedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z
edddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd	„Zy)r'   c                ó,   — t        | j                  «      S r*   )r
   r+   r,   s    r.   r/   zAsyncThreads.eventsæ   s   € ä˜4Ÿ<™<Ó(Ð(r0   c                ó   — t        | «      S r2   )ÚAsyncThreadsWithRawResponser,   s    r.   r4   zAsyncThreads.with_raw_responseê   s   € ô +¨4Ó0Ð0r0   c                ó   — t        | «      S r6   )Ú!AsyncThreadsWithStreamingResponser,   s    r.   r8   z$AsyncThreads.with_streaming_responseô   s   € ô 1°Ó6Ð6r0   Nr9   c          
   ƒ  ób  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{  –—† S 7 Œ­w)r@   rA   rB   rC   rD   c              3  ó2   K  — | ]  }t        |«      –— Œ y ­wr*   rF   rH   s     r.   rK   z(AsyncThreads.retrieve.<locals>.<genexpr>  rL   rM   rN   rO   rP   rS   rT   NrW   r[   s           r.   r\   zAsyncThreads.retrieveý   sï   è ø€ ñ6 ÜÐXÐYcÐXfÐgÓhÐhÙÜÐWÐXaÐWdÐeÓfÐfð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ—Y‘YÜØIÐV`Ðluôô )Ø+¸ÐQ[Ðelôô 3ð ó 
÷ 
ð 	
ð 
úó   ‚B&B/Â(B-Â)B/r]   c               ót  — |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        ¬
«      S )ra   rA   rC   rD   c              3  ó2   K  — | ]  }t        |«      –— Œ y ­wr*   rF   rH   s     r.   rK   z$AsyncThreads.list.<locals>.<genexpr>W  rL   rM   rN   rc   rd   re   rf   rh   )rX   r   r   rY   r   r   rj   r   r    r%   r"   r   r#   rk   rl   s	            r.   rm   zAsyncThreads.list1  sí   € ñB ÜÐXÐYcÐXfÐgÓhÐhð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ×!Ñ!ÜÐGÐT^Ô_Ü Ô!?Ñ@Ü(Ø+Ø'Ø%ØÜ%à!&Ø $ñô '×7Ñ7óôô 1ð! "ó 
ð 	
r0   c          
   ƒ  ób  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{  –—† S 7 Œ­w)ro   rA   rB   rC   rD   c              3  ó2   K  — | ]  }t        |«      –— Œ y ­wr*   rF   rH   s     r.   rK   z'AsyncThreads.archive.<locals>.<genexpr>”  rL   rM   rN   rq   rP   rS   rT   Nrr   r[   s           r.   rt   zAsyncThreads.archiver  sï   è ø€ ñ6 ÜÐXÐYcÐXfÐgÓhÐhÙÜÐWÐXaÐWdÐeÓfÐfð	
Üà$Ü ”ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"ðóð	
ð Ò" ð	
ˆð *Ð+FÐ`È=ÒK^Ð\^Ð`ˆØ—Z‘ZÜØQØ%Ø#ôô
 )Ø+¸ÐQ[Ðelôô 3ð  ó 

÷ 

ð 
	
ð 

úr‹   )ru   r
   )ru   r†   )ru   rˆ   rv   )rQ   rG   r^   r|   r_   r}   r:   rw   r;   rx   r<   ry   r=   rz   r>   r{   ru   z_AsyncPaginator[BetaManagedAgentsSessionThread, AsyncPageCursor[BetaManagedAgentsSessionThread]]r~   r‚   r0   r.   r'   r'   å   s�  „ Øò)ó ð)ð ò1ó ð1ð ò7ó ð7ð 26ð )-Ø$(Ø"&Ø;Dñ2
àð2
ð ð	2
ð
 /ð2
ð &ð2
ð "ð2
ð  ð2
ð 9ð2
ð 
(ó2
ðp !ØØ15ð )-Ø$(Ø"&Ø;Dñ?
àð?
ð ð	?
ð
 ð?
ð /ð?
ð &ð?
ð "ð?
ð  ð?
ð 9ð?
ð 
ió?
ðL 26ð )-Ø$(Ø"&Ø;Dñ4
àð4
ð ð	4
ð
 /ð4
ð &ð4
ð "ð4
ð  ð4
ð 9ð4
ð 
(ô4
r0   c                  ó&   — e Zd Zdd„Zedd„«       Zy)r3   c                óê   — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        t        j                  |j
                  «      | _        y r*   )Ú_threadsr   Úto_raw_response_wrapperr\   rm   rt   ©r-   Úthreadss     r.   Ú__init__zThreadsWithRawResponse.__init__ª  sZ   € ØˆŒä(×@Ñ@Ø×Ñó
ˆŒô %×<Ñ<Ø�L‰Ló
ˆŒ	ô (×?Ñ?Ø�O‰Oó
ˆ�r0   c                ó@   — t        | j                  j                  «      S r*   )r   r’   r/   r,   s    r.   r/   zThreadsWithRawResponse.events·  s   € ä$ T§]¡]×%9Ñ%9Ó:Ð:r0   N©r•   r&   ru   ÚNone)ru   r   ©r   r€   r�   r–   r   r/   r‚   r0   r.   r3   r3   ©  s   „ ó
ð ò;ó ñ;r0   r3   c                  ó&   — e Zd Zdd„Zedd„«       Zy)r†   c                óê   — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        t        j                  |j
                  «      | _        y r*   )r’   r   Úasync_to_raw_response_wrapperr\   rm   rt   r”   s     r.   r–   z$AsyncThreadsWithRawResponse.__init__½  sZ   € ØˆŒä(×FÑFØ×Ñó
ˆŒô %×BÑBØ�L‰Ló
ˆŒ	ô (×EÑEØ�O‰Oó
ˆ�r0   c                ó@   — t        | j                  j                  «      S r*   )r   r’   r/   r,   s    r.   r/   z"AsyncThreadsWithRawResponse.eventsÊ  s   € ä)¨$¯-©-×*>Ñ*>Ó?Ð?r0   N©r•   r'   ru   r™   )ru   r   rš   r‚   r0   r.   r†   r†   ¼  s   „ ó
ð ò@ó ñ@r0   r†   c                  ó&   — e Zd Zdd„Zedd„«       Zy)r7   c                ó®   — || _         t        |j                  «      | _        t        |j                  «      | _        t        |j                  «      | _        y r*   )r’   r   r\   rm   rt   r”   s     r.   r–   z%ThreadsWithStreamingResponse.__init__Ð  sH   € ØˆŒä4Ø×Ñó
ˆŒô 1Ø�L‰Ló
ˆŒ	ô 4Ø�O‰Oó
ˆ�r0   c                ó@   — t        | j                  j                  «      S r*   )r   r’   r/   r,   s    r.   r/   z#ThreadsWithStreamingResponse.eventsÝ  s   € ä*¨4¯=©=×+?Ñ+?Ó@Ð@r0   Nr˜   )ru   r   rš   r‚   r0   r.   r7   r7   Ï  s   „ ó
ð òAó ñAr0   r7   c                  ó&   — e Zd Zdd„Zedd„«       Zy)rˆ   c                ó®   — || _         t        |j                  «      | _        t        |j                  «      | _        t        |j                  «      | _        y r*   )r’   r   r\   rm   rt   r”   s     r.   r–   z*AsyncThreadsWithStreamingResponse.__init__ã  sH   € ØˆŒä:Ø×Ñó
ˆŒô 7Ø�L‰Ló
ˆŒ	ô :Ø�O‰Oó
ˆ�r0   c                ó@   — t        | j                  j                  «      S r*   )r   r’   r/   r,   s    r.   r/   z(AsyncThreadsWithStreamingResponse.eventsð  s   € ä/°·±×0DÑ0DÓEÐEr0   NrŸ   )ru   r   rš   r‚   r0   r.   rˆ   rˆ   â  s   „ ó
ð òFó ñFr0   rˆ   )8Ú
__future__r   Útypingr   Ú	itertoolsr   ÚhttpxÚ r   r/   r	   r
   r   r   r   r   Ú_typesr   r   r   r   r   r   r   Ú_utilsr   r   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r   Ú
paginationr   r    Ú_base_clientr!   r"   Útypes.beta.sessionsr#   Útypes.anthropic_beta_paramr$   Ú6types.beta.sessions.beta_managed_agents_session_threadr%   Ú__all__r&   r'   r3   r†   r7   rˆ   r‚   r0   r.   Ú<module>r¶      s¡   ðõ #å Ý ã å "÷÷ ÷ N× MÑ Mß QÓ QÝ (ß <ß [ß ;ß BÝ 7Ý >Ý fà�nÐ
%€ôA
ˆoô A
ôHA
Ð#ô A
÷H;ñ ;÷&@ñ @÷&Añ A÷&Fò Fr0   