§
    ÜŽ’jÀL  ã                  ó²  — 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¦  «        Z7dS )é    )Ú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dS )&r&   Úreturnr	   c                ó*   — t          | j        ¦  «        S ©N)r	   Ú_client©Úselfs    ú_C:\Projects\DSCons\.venv\Lib\site-packages\anthropic\resources\beta\sessions\threads\threads.pyÚeventszThreads.events"   s   € å�d”lÑ#Ô#Ð#ó    ÚThreadsWithRawResponsec                ó    — 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
        )r2   r-   s    r/   Úwith_raw_responsezThreads.with_raw_response&   s   € õ & dÑ+Ô+Ð+r1   ÚThreadsWithStreamingResponsec                ó    — 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
        )r6   r-   s    r/   Úwith_streaming_responsezThreads.with_streaming_response0   s   € õ ,¨DÑ1Ô1Ð1r1   N©ÚbetasÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutÚ	thread_idÚstrÚ
session_idr;   úList[AnthropicBetaParam] | Omitr<   úHeaders | Noner=   úQuery | Noner>   úBody | Noner?   ú'float | httpx.Timeout | None | NotGivenr%   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          ¬
¦  «        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  ó4   K  — | ]}t          |¦  «        V — Œd S r+   ©rA   ©Ú.0Úes     r/   ú	<genexpr>z#Threads.retrieve.<locals>.<genexpr>[   ó(   è è € Ð5LÐ5LÀµc¸!±f´fÐ5LÐ5LÐ5LÐ5LÐ5LÐ5Lr1   úmanaged-agents-2026-04-01ú7/v1/sessions/{session_id}/threads/{thread_id}?beta=true©rB   r@   ©r<   r=   r>   r?   ©ÚoptionsÚcast_to©
Ú
ValueErrorr   r   Újoinr   r   Ú_getr   r"   r%   ©r.   r@   rB   r;   r<   r=   r>   r?   s           r/   ÚretrievezThreads.retrieve9   s'  € ð6 ð 	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ÝØIÐV`Ðluðñ ô õ )Ø+¸ÐQ[Ðelðñ ô õ 3ð ñ 
ô 
ð 	
r1   ©ÚlimitÚpager;   r<   r=   r>   r?   rc   ú
int | Omitrd   ú
str | Omitú.SyncPageCursor[BetaManagedAgentsSessionThread]c               óÀ  — |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          ¬
¦  «        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
        rJ   rL   rM   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S r+   rO   rP   s     r/   rS   zThreads.list.<locals>.<genexpr>“   rT   r1   rU   ú+/v1/sessions/{session_id}/threads?beta=true©rB   ©rc   rd   ©r<   r=   r>   r?   Úquery©rd   rZ   Úmodel)r]   r   r   r^   r   r   Ú_get_api_listr   r   r%   r"   r   r#   ÚThreadListParams©	r.   rB   rc   rd   r;   r<   r=   r>   r?   s	            r/   ÚlistzThreads.listm   s-  € ðB ð 	iÝÐgÐYcÐgÐgÑhÔhÐhð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝÐGÐT^Ð_Ñ_Ô_ÝÕ >Ô?Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ 'Ô7ñô ðñ ô õ 1ð! "ñ 
ô 
ð 	
r1   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          ¬
¦  «        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
        rJ   rK   rL   rM   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S r+   rO   rP   s     r/   rS   z"Threads.archive.<locals>.<genexpr>Ð   rT   r1   rU   ú?/v1/sessions/{session_id}/threads/{thread_id}/archive?beta=truerW   rX   rY   ©
r]   r   r   r^   r   r   Ú_postr   r"   r%   r`   s           r/   ÚarchivezThreads.archive®   s'  € ð6 ð 	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^Ð\^Ð`ˆØ�zŠzÝØQØ%Ø#ðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 3ð ñ 

ô 

ð 
	
r1   )r)   r	   )r)   r2   )r)   r6   ©r@   rA   rB   rA   r;   rC   r<   rD   r=   rE   r>   rF   r?   rG   r)   r%   )rB   rA   rc   re   rd   rf   r;   rC   r<   rD   r=   rE   r>   rF   r?   rG   r)   rg   ©Ú__name__Ú
__module__Ú__qualname__r   r0   r5   r9   r   r   ra   ru   r|   © r1   r/   r&   r&   !   s  € € € € € Øð$ð $ð $ñ „_ð$ð ð,ð ,ð ,ñ „_ð,ð ð2ð 2ð 2ñ „_ð2ð 26ð )-Ø$(Ø"&Ø;Dð2
ð 2
ð 2
ð 2
ð 2
ð 2
ðp !ØØ15ð )-Ø$(Ø"&Ø;Dð?
ð ?
ð ?
ð ?
ð ?
ð ?
ðL 26ð )-Ø$(Ø"&Ø;Dð4
ð 4
ð 4
ð 4
ð 4
ð 4
ð 4
ð 4
r1   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dS )&r'   r)   r
   c                ó*   — t          | j        ¦  «        S r+   )r
   r,   r-   s    r/   r0   zAsyncThreads.eventsæ   s   € å˜4œ<Ñ(Ô(Ð(r1   ÚAsyncThreadsWithRawResponsec                ó    — t          | ¦  «        S r4   )r…   r-   s    r/   r5   zAsyncThreads.with_raw_responseê   s   € õ +¨4Ñ0Ô0Ð0r1   Ú!AsyncThreadsWithStreamingResponsec                ó    — t          | ¦  «        S r8   )r‡   r-   s    r/   r9   z$AsyncThreads.with_streaming_responseô   s   € õ 1°Ñ6Ô6Ð6r1   Nr:   r@   rA   rB   r;   rC   r<   rD   r=   rE   r>   rF   r?   rG   r%   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{V —†S )rI   rJ   rK   rL   rM   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S r+   rO   rP   s     r/   rS   z(AsyncThreads.retrieve.<locals>.<genexpr>  rT   r1   rU   rV   rW   rX   rY   Nr\   r`   s           r/   ra   zAsyncThreads.retrieveý   sI  è è € ð6 ð 	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ÝØIÐV`Ðluðñ ô õ )Ø+¸ÐQ[Ðelðñ ô õ 3ð ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
r1   rb   rc   re   rd   rf   ú_AsyncPaginator[BetaManagedAgentsSessionThread, AsyncPageCursor[BetaManagedAgentsSessionThread]]c               óÀ  — |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          ¬
¦  «        S )ri   rJ   rL   rM   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S r+   rO   rP   s     r/   rS   z$AsyncThreads.list.<locals>.<genexpr>W  rT   r1   rU   rk   rl   rm   rn   rp   )r]   r   r   r^   r   r   rr   r   r    r%   r"   r   r#   rs   rt   s	            r/   ru   zAsyncThreads.list1  s-  € ðB ð 	iÝÐgÐYcÐgÐgÑhÔhÐhð	
Ýà$Ý ‘”ð'# c§h¢h­uÐ5LÐ5LÀeÐ5LÑ5LÔ5LÐOjÐNkÑ/lÔ/lÑ&mÔ&mÐ&må"ðñô ð	
ð Ð" ð	
ˆð *Ð+FÐ`È=ÐK^Ð\^Ð`ˆØ×!Ò!ÝÐGÐT^Ð_Ñ_Ô_Ý Õ!?Ô@Ý(Ø+Ø'Ø%ØÝ%à!&Ø $ðð õ 'Ô7ñô ðñ ô õ 1ð! "ñ 
ô 
ð 	
r1   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{V —†S )rw   rJ   rK   rL   rM   c              3  ó4   K  — | ]}t          |¦  «        V — Œd S r+   rO   rP   s     r/   rS   z'AsyncThreads.archive.<locals>.<genexpr>”  rT   r1   rU   ry   rW   rX   rY   Nrz   r`   s           r/   r|   zAsyncThreads.archiver  sI  è è € ð6 ð 	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^Ð\^Ð`ˆØ—Z’ZÝØQØ%Ø#ðñ ô õ
 )Ø+¸ÐQ[Ðelðñ ô õ 3ð  ñ 

ô 

ð 

ð 

ð 

ð 

ð 

ð 

ð 
	
r1   )r)   r
   )r)   r…   )r)   r‡   r}   )rB   rA   rc   re   rd   rf   r;   rC   r<   rD   r=   rE   r>   rF   r?   rG   r)   r‹   r~   r‚   r1   r/   r'   r'   å   s  € € € € € Øð)ð )ð )ñ „_ð)ð ð1ð 1ð 1ñ „_ð1ð ð7ð 7ð 7ñ „_ð7ð 26ð )-Ø$(Ø"&Ø;Dð2
ð 2
ð 2
ð 2
ð 2
ð 2
ðp !ØØ15ð )-Ø$(Ø"&Ø;Dð?
ð ?
ð ?
ð ?
ð ?
ð ?
ðL 26ð )-Ø$(Ø"&Ø;Dð4
ð 4
ð 4
ð 4
ð 4
ð 4
ð 4
ð 4
r1   c                  ó.   — e Zd Zd	d„Zed
d„¦   «         ZdS )r2   Úthreadsr&   r)   ÚNonec                óÈ   — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        d S r+   )Ú_threadsr   Úto_raw_response_wrapperra   ru   r|   ©r.   r‘   s     r/   Ú__init__zThreadsWithRawResponse.__init__ª  s]   € ØˆŒå(Ô@ØÔñ
ô 
ˆŒõ %Ô<ØŒLñ
ô 
ˆŒ	õ (Ô?ØŒOñ
ô 
ˆŒˆˆr1   r   c                ó4   — t          | j        j        ¦  «        S r+   )r   r”   r0   r-   s    r/   r0   zThreadsWithRawResponse.events·  s   € å$ T¤]Ô%9Ñ:Ô:Ð:r1   N©r‘   r&   r)   r’   )r)   r   ©r   r€   r�   r—   r   r0   r‚   r1   r/   r2   r2   ©  sH   € € € € € ð
ð 
ð 
ð 
ð ð;ð ;ð ;ñ „_ð;ð ;ð ;r1   r2   c                  ó.   — e Zd Zd	d„Zed
d„¦   «         ZdS )r…   r‘   r'   r)   r’   c                óÈ   — || _         t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        t          j        |j        ¦  «        | _        d S r+   )r”   r   Úasync_to_raw_response_wrapperra   ru   r|   r–   s     r/   r—   z$AsyncThreadsWithRawResponse.__init__½  s]   € ØˆŒå(ÔFØÔñ
ô 
ˆŒõ %ÔBØŒLñ
ô 
ˆŒ	õ (ÔEØŒOñ
ô 
ˆŒˆˆr1   r   c                ó4   — t          | j        j        ¦  «        S r+   )r   r”   r0   r-   s    r/   r0   z"AsyncThreadsWithRawResponse.eventsÊ  s   € å)¨$¬-Ô*>Ñ?Ô?Ð?r1   N©r‘   r'   r)   r’   )r)   r   rš   r‚   r1   r/   r…   r…   ¼  sN   € € € € € ð
ð 
ð 
ð 
ð ð@ð @ð @ñ „_ð@ð @ð @r1   r…   c                  ó.   — e Zd Zd	d„Zed
d„¦   «         ZdS )r6   r‘   r&   r)   r’   c                óª   — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        d S r+   )r”   r   ra   ru   r|   r–   s     r/   r—   z%ThreadsWithStreamingResponse.__init__Ð  sT   € ØˆŒå4ØÔñ
ô 
ˆŒõ 1ØŒLñ
ô 
ˆŒ	õ 4ØŒOñ
ô 
ˆŒˆˆr1   r   c                ó4   — t          | j        j        ¦  «        S r+   )r   r”   r0   r-   s    r/   r0   z#ThreadsWithStreamingResponse.eventsÝ  s   € å*¨4¬=Ô+?Ñ@Ô@Ð@r1   Nr™   )r)   r   rš   r‚   r1   r/   r6   r6   Ï  sN   € € € € € ð
ð 
ð 
ð 
ð ðAð Að Añ „_ðAð Að Ar1   r6   c                  ó.   — e Zd Zd	d„Zed
d„¦   «         ZdS )r‡   r‘   r'   r)   r’   c                óª   — || _         t          |j        ¦  «        | _        t          |j        ¦  «        | _        t          |j        ¦  «        | _        d S r+   )r”   r   ra   ru   r|   r–   s     r/   r—   z*AsyncThreadsWithStreamingResponse.__init__ã  sT   € ØˆŒå:ØÔñ
ô 
ˆŒõ 7ØŒLñ
ô 
ˆŒ	õ :ØŒOñ
ô 
ˆŒˆˆr1   r   c                ó4   — t          | j        j        ¦  «        S r+   )r   r”   r0   r-   s    r/   r0   z(AsyncThreadsWithStreamingResponse.eventsð  s   € å/°´Ô0DÑEÔEÐEr1   NrŸ   )r)   r   rš   r‚   r1   r/   r‡   r‡   â  sN   € € € € € ð
ð 
ð 
ð 
ð ðFð Fð Fñ „_ðFð Fð Fr1   r‡   )8Ú
__future__r   Útypingr   Ú	itertoolsr   ÚhttpxÚ r   r0   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'   r2   r…   r6   r‡   r‚   r1   r/   ú<module>r¶      sâ  ðð #Ð "Ð "Ð "Ð "Ð "à Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð à €€€à "Ð "Ð "Ð "Ð "Ð "ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð NÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MÐ MØ QÐ QÐ QÐ QÐ QÐ QÐ QÐ QÐ QÐ QÐ QÐ QØ (Ð (Ð (Ð (Ð (Ð (Ø <Ð <Ð <Ð <Ð <Ð <Ð <Ð <Ø [Ð [Ð [Ð [Ð [Ð [Ð [Ð [Ø ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ø BÐ BÐ BÐ BÐ BÐ BÐ BÐ BØ 7Ð 7Ð 7Ð 7Ð 7Ð 7Ø >Ð >Ð >Ð >Ð >Ð >Ø fÐ fÐ fÐ fÐ fÐ fà�nÐ
%€ðA
ð A
ð A
ð A
ð A
ˆoñ A
ô A
ð A
ðHA
ð A
ð A
ð A
ð A
Ð#ñ A
ô A
ð A
ðH;ð ;ð ;ð ;ð ;ñ ;ô ;ð ;ð&@ð @ð @ð @ð @ñ @ô @ð @ð&Að Að Að Að Añ Aô Að Að&Fð Fð Fð Fð Fñ Fô Fð Fð Fð Fr1   