ó
    ±"³j…T  ã                  óx  • S SK Jr  S SKJr  S SKJr  S SKrSSK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JrJr  SS	K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!J"r"J#r#  SSK$J%r%J&r&  SSK'J(r(J)r)  SSK*J+r+  SSK,J-r-  SS/r. " S S\5      r/ " S S\5      r0 " S S5      r1 " S S5      r2 " S S5      r3 " S S5      r4g)é    )Úannotations)ÚList)ÚchainNé   )ÚEventsÚAsyncEventsÚEventsWithRawResponseÚAsyncEventsWithRawResponseÚEventsWithStreamingResponseÚ AsyncEventsWithStreamingResponseé   )ÚBodyÚOmitÚQueryÚHeadersÚNotGivenÚomitÚ	not_given)Úis_givenÚpath_templateÚstrip_not_given)Úcached_property)ÚSyncAPIResourceÚAsyncAPIResource)Úto_raw_response_wrapperÚto_streamed_response_wrapperÚasync_to_raw_response_wrapperÚ"async_to_streamed_response_wrapper)ÚSyncPageCursorÚAsyncPageCursor)ÚAsyncPaginatorÚmake_request_options)ÚAnthropicBetaParam)ÚBetaManagedAgentsSessionThreadÚThreadsÚAsyncThreadsc            	      ó  • \ rS rSr\SS j5       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 R                  5      $ ©N)r   Ú_client©Úselfs    Ún/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anthropic/resources/beta/sessions/threads/threads.pyÚeventsÚThreads.events#   s   € ä�d—l‘lÓ#Ð#ó    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
)ÚThreadsWithRawResponser,   s    r.   Úwith_raw_responseÚThreads.with_raw_response'   s   € ô & dÓ+Ð+r1   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
)ÚThreadsWithStreamingResponser,   s    r.   Úwith_streaming_responseÚThreads.with_streaming_response1   s   € ô ,¨DÓ1Ð1r1   N©ÚbetasÚworkspace_idÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc          
     óf  • U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SX!S	9[        XVXxS
9[        S9$ )áµ  
Get Session Thread

Args:
  betas: Optional header to specify the beta version(s) you want to use.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  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 Ú,c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   ©Ústr©Ú.0Úes     r.   Ú	<genexpr>Ú#Threads.retrieve.<locals>.<genexpr>d   ó   é € Ð5LÂeÀ´c¸!·f°fÂeùó   ‚úmanaged-agents-2026-04-01©úanthropic-betazanthropic-workspace-idrT   ú7/v1/sessions/{session_id}/threads/{thread_id}?beta=true©Ú
session_idÚ	thread_id©r?   r@   rA   rB   ©ÚoptionsÚcast_to©
Ú
ValueErrorr   r   Újoinr   r   Ú_getr   r"   r$   ©	r-   rX   rW   r=   r>   r?   r@   rA   rB   s	            r.   ÚretrieveÚThreads.retrieve:   sÞ   € öF ÜÐ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`ñô )Ø+ÐQ[ñô 3ð ð 
ð 	
r1   ©ÚlimitÚpager=   r>   r?   r@   rA   rB   c               ó^  • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.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S	.S
9[        S9$ )áE  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.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  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
rE   rG   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   rI   rK   s     r.   rN   ÚThreads.list.<locals>.<genexpr>¥   rP   rQ   rR   rS   rT   ú+/v1/sessions/{session_id}/threads?beta=true©rW   ©re   rf   ©r?   r@   rA   rB   Úquery©rf   r[   Úmodel)r^   r   r   r_   r   r   Ú_get_api_listr   r   r$   r"   ©
r-   rW   re   rf   r=   r>   r?   r@   rA   rB   s
             r.   ÚlistÚThreads.listw   sÞ   € öR ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ×!Ñ!ÜÐGÐT^Ñ_ÜÔ >Ñ?Ü(Ø+Ø'Ø%Øà"Ø ññ	ô 1ð "ð 
ð 	
r1   c          
     óh  • U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS	9[        XVXxS
9[        S9$ )á¹  
Archive Session Thread

Args:
  betas: Optional header to specify the beta version(s) you want to use.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  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
rE   rF   rG   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   rI   rK   s     r.   rN   Ú"Threads.archive.<locals>.<genexpr>è   rP   rQ   rR   rS   rT   ú?/v1/sessions/{session_id}/threads/{thread_id}/archive?beta=truerV   rY   rZ   ©
r^   r   r   r_   r   r   Ú_postr   r"   r$   ra   s	            r.   ÚarchiveÚThreads.archive¾   sá   € öF ÜÐ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[ñô 3ð ð 

ð 
	
r1   © )Úreturnr   )r€   r4   )r€   r9   ©rX   rJ   rW   rJ   r=   úList[AnthropicBetaParam] | Omitr>   ú
str | Omitr?   úHeaders | Noner@   úQuery | NonerA   úBody | NonerB   ú(float | httpx2.Timeout | None | NotGivenr€   r$   )rW   rJ   re   ú
int | Omitrf   rƒ   r=   r‚   r>   rƒ   r?   r„   r@   r…   rA   r†   rB   r‡   r€   z.SyncPageCursor[BetaManagedAgentsSessionThread]©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r/   r5   r:   r   r   rb   rt   r}   Ú__static_attributes__r   r1   r.   r%   r%   "   s·  † Øó$ó ð$ð ó,ó ð,ð ó2ó ð2ð 26Ø#'ð )-Ø$(Ø"&Ø<Eñ;
àð;
ð ð	;
ð
 /ð;
ð !ð;
ð &ð;
ð "ð;
ð  ð;
ð :ð;
ð 
(õ;
ðB !ØØ15Ø#'ð )-Ø$(Ø"&Ø<EñE
àðE
ð ð	E
ð
 ðE
ð /ðE
ð !ðE
ð &ðE
ð "ðE
ð  ðE
ð :ðE
ð 
8õE
ðX 26Ø#'ð )-Ø$(Ø"&Ø<Eñ=
àð=
ð ð	=
ð
 /ð=
ð !ð=
ð &ð=
ð "ð=
ð  ð=
ð :ð=
ð 
(÷=
ð =
r1   c            	      ó  • \ rS rSr\SS j5       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 R                  5      $ r*   )r   r+   r,   s    r.   r/   ÚAsyncThreads.eventsÿ   s   € ä˜4Ÿ<™<Ó(Ð(r1   c                ó   • [        U 5      $ r3   )ÚAsyncThreadsWithRawResponser,   s    r.   r5   ÚAsyncThreads.with_raw_response  s   € ô +¨4Ó0Ð0r1   c                ó   • [        U 5      $ r8   )Ú!AsyncThreadsWithStreamingResponser,   s    r.   r:   Ú$AsyncThreads.with_streaming_response  s   € ô 1°Ó6Ð6r1   Nr<   c          
   ƒ  ó‚  #   • U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SX!S	9[        XVXxS
9[        S9I Sh  v•N $  N7f)rD   rE   rF   rG   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   rI   rK   s     r.   rN   Ú(AsyncThreads.retrieve.<locals>.<genexpr>@  rP   rQ   rR   rS   rT   rU   rV   rY   rZ   Nr]   ra   s	            r.   rb   ÚAsyncThreads.retrieve  së   é € öF ÜÐ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`ñô )Ø+ÐQ[ñô 3ð ð 
÷ 
ð 	
ñ 
ùs   ‚B6B?Â8B=Â9B?rd   c               ó^  • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.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S	.S
9[        S9$ )rh   rE   rG   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   rI   rK   s     r.   rN   Ú$AsyncThreads.list.<locals>.<genexpr>�  rP   rQ   rR   rS   rT   rk   rl   rm   rn   rp   )r^   r   r   r_   r   r   rr   r   r    r$   r"   rs   s
             r.   rt   ÚAsyncThreads.listS  sÞ   € öR ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ×!Ñ!ÜÐGÐT^Ñ_Ü Ô!?Ñ@Ü(Ø+Ø'Ø%Øà"Ø ññ	ô 1ð "ð 
ð 	
r1   c          
   ƒ  ó„  #   • U(       d  [        SU< 35      eU(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUUS	9[        XVXxS
9[        S9I Sh  v•N $  N7f)rw   rE   rF   rG   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7fr*   rI   rK   s     r.   rN   Ú'AsyncThreads.archive.<locals>.<genexpr>Ä  rP   rQ   rR   rS   rT   rz   rV   rY   rZ   Nr{   ra   s	            r.   r}   ÚAsyncThreads.archiveš  sî   é € öF ÜÐ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[ñô 3ð  ð 

÷ 

ð 
	
ñ 

ùs   ‚B7C Â9B>Â:C r   )r€   r   )r€   r”   )r€   r—   r�   )rW   rJ   re   rˆ   rf   rƒ   r=   r‚   r>   rƒ   r?   r„   r@   r…   rA   r†   rB   r‡   r€   z_AsyncPaginator[BetaManagedAgentsSessionThread, AsyncPageCursor[BetaManagedAgentsSessionThread]]r‰   r   r1   r.   r&   r&   þ   s¸  † Øó)ó ð)ð ó1ó ð1ð ó7ó ð7ð 26Ø#'ð )-Ø$(Ø"&Ø<Eñ;
àð;
ð ð	;
ð
 /ð;
ð !ð;
ð &ð;
ð "ð;
ð  ð;
ð :ð;
ð 
(õ;
ðB !ØØ15Ø#'ð )-Ø$(Ø"&Ø<EñE
àðE
ð ð	E
ð
 ðE
ð /ðE
ð !ðE
ð &ðE
ð "ðE
ð  ðE
ð :ðE
ð 
iõE
ðX 26Ø#'ð )-Ø$(Ø"&Ø<Eñ=
àð=
ð ð	=
ð
 /ð=
ð !ð=
ð &ð=
ð "ð=
ð  ð=
ð :ð=
ð 
(÷=
ð =
r1   c                  ó2   • \ rS rSrSS jr\SS j5       rSrg)r4   iÚ  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g r*   )Ú_threadsr   rb   rt   r}   ©r-   Úthreadss     r.   Ú__init__ÚThreadsWithRawResponse.__init__Û  sF   € ØŒä/Ø×Ñó
ˆŒô ,Ø�L‰Ló
ˆŒ	ô /Ø�O‰Oó
ˆ�r1   c                ó@   • [        U R                  R                  5      $ r*   )r	   r§   r/   r,   s    r.   r/   ÚThreadsWithRawResponse.eventsè  s   € ä$ T§]¡]×%9Ñ%9Ó:Ð:r1   ©r§   r}   rt   rb   N©r©   r%   r€   ÚNone)r€   r	   ©rŠ   r‹   rŒ   r�   rª   r   r/   rŽ   r   r1   r.   r4   r4   Ú  s   † ô
ð ó;ó ó;r1   r4   c                  ó2   • \ rS rSrSS jr\SS j5       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 r*   )r§   r   rb   rt   r}   r¨   s     r.   rª   Ú$AsyncThreadsWithRawResponse.__init__î  sF   € ØŒä5Ø×Ñó
ˆŒô 2Ø�L‰Ló
ˆŒ	ô 5Ø�O‰Oó
ˆ�r1   c                ó@   • [        U R                  R                  5      $ r*   )r
   r§   r/   r,   s    r.   r/   Ú"AsyncThreadsWithRawResponse.eventsû  s   € ä)¨$¯-©-×*>Ñ*>Ó?Ð?r1   r®   N©r©   r&   r€   r°   )r€   r
   r±   r   r1   r.   r”   r”   í  s   † ô
ð ó@ó ó@r1   r”   c                  ó2   • \ rS rSrSS jr\SS j5       rSrg)r9   i   c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g r*   )r§   r   rb   rt   r}   r¨   s     r.   rª   Ú%ThreadsWithStreamingResponse.__init__  sF   € ØŒä4Ø×Ñó
ˆŒô 1Ø�L‰Ló
ˆŒ	ô 4Ø�O‰Oó
ˆ�r1   c                ó@   • [        U R                  R                  5      $ r*   )r   r§   r/   r,   s    r.   r/   Ú#ThreadsWithStreamingResponse.events  s   € ä*¨4¯=©=×+?Ñ+?Ó@Ð@r1   r®   Nr¯   )r€   r   r±   r   r1   r.   r9   r9      s   † ô
ð óAó óAr1   r9   c                  ó2   • \ rS rSrSS jr\SS j5       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 r*   )r§   r   rb   rt   r}   r¨   s     r.   rª   Ú*AsyncThreadsWithStreamingResponse.__init__  sF   € ØŒä:Ø×Ñó
ˆŒô 7Ø�L‰Ló
ˆŒ	ô :Ø�O‰Oó
ˆ�r1   c                ó@   • [        U R                  R                  5      $ r*   )r   r§   r/   r,   s    r.   r/   Ú(AsyncThreadsWithStreamingResponse.events!  s   € ä/°·±×0DÑ0DÓEÐEr1   r®   Nr·   )r€   r   r±   r   r1   r.   r—   r—     s   † ô
ð óFó óFr1   r—   )5Ú
__future__r   Útypingr   Ú	itertoolsr   Úhttpx2r/   r   r   r	   r
   r   r   Ú_typesr   r   r   r   r   r   r   Ú_utilsr   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r   r   r   Ú
paginationr   r    Ú_base_clientr!   r"   Útypes.anthropic_beta_paramr#   Ú6types.beta.sessions.beta_managed_agents_session_threadr$   Ú__all__r%   r&   r4   r”   r9   r—   r   r1   r.   Ú<module>rÐ      s¢   ðÝ "å Ý ã ÷÷ ÷ N× MÑ Mß @Ñ @Ý (ß <÷ó ÷ <ß BÝ >Ý fà�nÐ
%€ôY
ˆoô Y
ôxY
Ð#ô Y
÷x;ñ ;÷&@ñ @÷&Añ A÷&Fò Fr1   