+
    ~jJ                       ^ RI Ht ^ RIHt ^ RIHt ^ RIt^RIHt ^RI	H
t
HtHtHtHtHt ^RIHtHtHtHtHtHtHt ^RIHtHtHtHt ^R	IHt ^R
IH t H!t! ^RI"H#t#H$t$ ^RI%H&t&H't' ^RI(H)t)H*t* ^RI+H,t, ^RI-H.t. ^RI/H0t0 RR.t1 ! R R] 4      t2 ! R R]!4      t3 ! R R4      t4 ! R R4      t5 ! R R4      t6 ! R R4      t7R# )    )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                      ] tR t^!t]R R l4       t]R R l4       t]R R l4       tR]RR	R
R	RR	R]	/R R llt
R]R]R]RR	R
R	RR	R]	/R R lltR]RR	R
R	RR	R]	/R R lltRtR	# )r$   c                   V ^8  d   QhRR/# )   returnr    )formats   "چ/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/anthropic/resources/beta/sessions/threads/threads.py__annotate__Threads.__annotate__#   s     $ $ $    c                	,    \        V P                  4      # N)r   _clientselfs   &r,   eventsThreads.events"   s    dll##r/   c                   V ^8  d   QhRR/# )r(   r)   ThreadsWithRawResponser*   )r+   s   "r,   r-   r.   '   s     , ,#9 ,r/   c                    \        V 4      # 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
)r8   r3   s   &r,   with_raw_responseThreads.with_raw_response&   s     &d++r/   c                   V ^8  d   QhRR/# )r(   r)   ThreadsWithStreamingResponser*   )r+   s   "r,   r-   r.   1   s     2 2)E 2r/   c                    \        V 4      # 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
)r>   r3   s   &r,   with_streaming_responseThreads.with_streaming_response0   s     ,D11r/   betasextra_headersNextra_query
extra_bodytimeoutc               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# r(   	thread_idstr
session_idrC   List[AnthropicBetaParam] | OmitrD   Headers | NonerE   Query | NonerF   Body | NonerG   'float | httpx.Timeout | None | NotGivenr)   r#   r*   )r+   s   "r,   r-   r.   9   Z     2
 2
2
 	2

 /2
 &2
 "2
  2
 92
 
(2
r/   c          
        V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RW!R7      \        WEWgR	7      \        R
7      # )X  
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  8   "   T F  p\        V4      x  K  	  R # 5ir1   rK   .0es   & r,   	<genexpr>#Threads.retrieve.<locals>.<genexpr>[        5Lec!ffe   managed-agents-2026-04-017/v1/sessions/{session_id}/threads/{thread_id}?beta=truerL   rJ   rD   rE   rF   rG   optionscast_to

ValueErrorr   r   joinr   r   _getr   r    r#   r4   rJ   rL   rC   rD   rE   rF   rG   s   &&$$$$$$r,   retrieveThreads.retrieve9   s    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`yyIV` )+Q[ 3  
 	
r/   limitpagec               <    V ^8  d   QhRRRRRRRRR	R
RRRRRRRR/	# )r(   rL   rK   rp   
int | Omitrq   
str | OmitrC   rM   rD   rN   rE   rO   rF   rP   rG   rQ   r)   z.SyncPageCursor[BetaManagedAgentsSessionThread]r*   )r+   s   "r,   r-   r.   m   sd     ?
 ?
?
 	?

 ?
 /?
 &?
 "?
  ?
 9?
 
8?
r/   c                  V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        \        ,          \        VVVV\        RVR	V/\        P                  4      R
7      \        R7      # )  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
rU   rW   rX   c              3  8   "   T F  p\        V4      x  K  	  R # 5ir1   rZ   r[   s   & r,   r^   Threads.list.<locals>.<genexpr>   r`   ra   rb   +/v1/sessions/{session_id}/threads?beta=truerL   rp   rq   rD   rE   rF   rG   queryrq   rg   model)rj   r   r   rk   r   r   _get_api_listr   r   r#   r    r   r!   ThreadListParams	r4   rL   rp   rq   rC   rD   rE   rF   rG   s	   &&$$$$$$$r,   listThreads.listm   s    B XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`!!GT^_ >?(+'%% '77 1! " 
 	
r/   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# rI   r*   )r+   s   "r,   r-   r.      Z     4
 4
4
 	4

 /4
 &4
 "4
  4
 94
 
(4
r/   c          
        V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        WEWgR	7      \        R
7      # )\  
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
rU   rV   rW   rX   c              3  8   "   T F  p\        V4      x  K  	  R # 5ir1   rZ   r[   s   & r,   r^   "Threads.archive.<locals>.<genexpr>   r`   ra   rb   ?/v1/sessions/{session_id}/threads/{thread_id}/archive?beta=truerd   re   rf   
rj   r   r   rk   r   r   _postr   r    r#   rm   s   &&$$$$$$r,   archiveThreads.archive   s    6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`zzQ%#
 )+Q[ 3  

 
	
r/   r*   __name__
__module____qualname____firstlineno__r   r5   r;   rA   r   r   rn   r   r   __static_attributes__r*   r/   r,   r$   r$   !   s    $ $ , , 2 22

 262
 )-2
 %)2
 #'2
 <E2
h?
 !	?

  ?
 26?
 )-?
 %)?
 #'?
 <E?
B4

 264
 )-4
 %)4
 #'4
 <E4
 4
r/   c                      ] tR t^t]R R l4       t]R R l4       t]R R l4       tR]RR	R
R	RR	R]	/R R llt
R]R]R]RR	R
R	RR	R]	/R R lltR]RR	R
R	RR	R]	/R R lltRtR	# )r%   c                   V ^8  d   QhRR/# )r(   r)   r   r*   )r+   s   "r,   r-   AsyncThreads.__annotate__   s     ) ) )r/   c                	,    \        V P                  4      # r1   )r   r2   r3   s   &r,   r5   AsyncThreads.events   s    4<<((r/   c                   V ^8  d   QhRR/# )r(   r)   AsyncThreadsWithRawResponser*   )r+   s   "r,   r-   r      s     1 1#> 1r/   c                    \        V 4      # r:   )r   r3   s   &r,   r;   AsyncThreads.with_raw_response   s     +400r/   c                   V ^8  d   QhRR/# )r(   r)   !AsyncThreadsWithStreamingResponser*   )r+   s   "r,   r-   r      s     7 7)J 7r/   c                    \        V 4      # r@   )r   r3   s   &r,   rA   $AsyncThreads.with_streaming_response   s     166r/   rC   rD   NrE   rF   rG   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# rI   r*   )r+   s   "r,   r-   r      rR   r/   c          
       "   V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RW!R7      \        WEWgR	7      \        R
7      G Rj  xL
 #  L5i)rT   rU   rV   rW   rX   c              3  8   "   T F  p\        V4      x  K  	  R # 5ir1   rZ   r[   s   & r,   r^   (AsyncThreads.retrieve.<locals>.<genexpr>  r`   ra   rb   rc   rd   re   rf   Nri   rm   s   &&$$$$$$r,   rn   AsyncThreads.retrieve   s     6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`YYIV` )+Q[ 3  
 
 	
 
s#   CAC C5CC
Crp   rq   c               <    V ^8  d   QhRRRRRRRRR	R
RRRRRRRR/	# )r(   rL   rK   rp   rs   rq   rt   rC   rM   rD   rN   rE   rO   rF   rP   rG   rQ   r)   z_AsyncPaginator[BetaManagedAgentsSessionThread, AsyncPageCursor[BetaManagedAgentsSessionThread]]r*   )r+   s   "r,   r-   r   1  se     ?
 ?
?
 	?

 ?
 /?
 &?
 "?
  ?
 9?
 
i?
r/   c                  V'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVR7      \        \        ,          \        VVVV\        RVR	V/\        P                  4      R
7      \        R7      # )rv   rU   rW   rX   c              3  8   "   T F  p\        V4      x  K  	  R # 5ir1   rZ   r[   s   & r,   r^   $AsyncThreads.list.<locals>.<genexpr>W  r`   ra   rb   ry   rz   rp   rq   r{   r}   )rj   r   r   rk   r   r   r   r   r   r#   r    r   r!   r   r   s	   &&$$$$$$$r,   r   AsyncThreads.list1  s    B XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`!!GT^_ !?@(+'%% '77 1! " 
 	
r/   c               8    V ^8  d   QhRRRRRRRRRR	R
RRRRR/# rI   r*   )r+   s   "r,   r-   r   r  r   r/   c          
       "   V'       g   \        RV: 24      hV'       g   \        RV: 24      h/ \        R\        V4      '       d$   RP                  \	        R V 4       R.4      4      M\
        /4      CT;'       g    / CpRR/T;'       g    / CpV P                  \        RVVR7      \        WEWgR	7      \        R
7      G Rj  xL
 #  L5i)r   rU   rV   rW   rX   c              3  8   "   T F  p\        V4      x  K  	  R # 5ir1   rZ   r[   s   & r,   r^   'AsyncThreads.archive.<locals>.<genexpr>  r`   ra   rb   r   rd   re   rf   Nr   rm   s   &&$$$$$$r,   r   AsyncThreads.archiver  s     6 XYcXfghhWXaWdeff	
$ '*hhu5Le5LOjNk/l&m"	
 ""	
 *+F`=K^K^\^`ZZQ%#
 )+Q[ 3   

 

 
	
 

s#   CAC C6CCCr*   r   r*   r/   r,   r%   r%      s    ) ) 1 1 7 72

 262
 )-2
 %)2
 #'2
 <E2
h?
 !	?

  ?
 26?
 )-?
 %)?
 #'?
 <E?
B4

 264
 )-4
 %)4
 #'4
 <E4
 4
r/   c                  8    ] tR tRtR R lt]R R l4       tRtR# )r8   i  c                    V ^8  d   QhRRRR/# r(   threadsr$   r)   Noner*   )r+   s   "r,   r-   #ThreadsWithRawResponse.__annotate__       
 
 
D 
r/   c                	    Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        R # r1   )_threadsr   to_raw_response_wrapperrn   r   r   r4   r   s   &&r,   __init__ThreadsWithRawResponse.__init__  sX    (@@
 %<<LL
	 (??OO
r/   c                   V ^8  d   QhRR/# )r(   r)   r	   r*   )r+   s   "r,   r-   r     s     ; ;- ;r/   c                	@    \        V P                  P                  4      # r1   )r	   r   r5   r3   s   &r,   r5   ThreadsWithRawResponse.events  s    $T]]%9%9::r/   r   r   r   rn   Nr   r   r   r   r   r   r5   r   r*   r/   r,   r8   r8     s    
 ; ;r/   r8   c                  8    ] tR tRtR R lt]R R l4       tRtR# )r   i  c                    V ^8  d   QhRRRR/# r(   r   r%   r)   r   r*   )r+   s   "r,   r-   (AsyncThreadsWithRawResponse.__annotate__       
 
 
 
r/   c                	    Wn         \        P                  ! VP                  4      V n        \        P                  ! VP                  4      V n        \        P                  ! VP
                  4      V n        R # r1   )r   r   async_to_raw_response_wrapperrn   r   r   r   s   &&r,   r   $AsyncThreadsWithRawResponse.__init__  sX    (FF
 %BBLL
	 (EEOO
r/   c                   V ^8  d   QhRR/# )r(   r)   r
   r*   )r+   s   "r,   r-   r     s     @ @2 @r/   c                	@    \        V P                  P                  4      # r1   )r
   r   r5   r3   s   &r,   r5   "AsyncThreadsWithRawResponse.events  s    )$--*>*>??r/   r   Nr   r*   r/   r,   r   r     s    
 @ @r/   r   c                  8    ] tR tRtR R lt]R R l4       tRtR# )r>   i  c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   )ThreadsWithStreamingResponse.__annotate__  r   r/   c                	    Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        R # r1   )r   r   rn   r   r   r   s   &&r,   r   %ThreadsWithStreamingResponse.__init__  sF    4
 1LL
	 4OO
r/   c                   V ^8  d   QhRR/# )r(   r)   r   r*   )r+   s   "r,   r-   r     s     A A3 Ar/   c                	@    \        V P                  P                  4      # r1   )r   r   r5   r3   s   &r,   r5   #ThreadsWithStreamingResponse.events  s    *4==+?+?@@r/   r   Nr   r*   r/   r,   r>   r>     s    
 A Ar/   r>   c                  8    ] tR tRtR R lt]R R l4       tRtR# )r   i  c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   .AsyncThreadsWithStreamingResponse.__annotate__  r   r/   c                	    Wn         \        VP                  4      V n        \        VP                  4      V n        \        VP                  4      V n        R # r1   )r   r   rn   r   r   r   s   &&r,   r   *AsyncThreadsWithStreamingResponse.__init__  sF    :
 7LL
	 :OO
r/   c                   V ^8  d   QhRR/# )r(   r)   r   r*   )r+   s   "r,   r-   r     s     F F8 Fr/   c                	@    \        V P                  P                  4      # r1   )r   r   r5   r3   s   &r,   r5   (AsyncThreadsWithStreamingResponse.events  s    /0D0DEEr/   r   Nr   r*   r/   r,   r   r     s    
 F Fr/   r   )8
__future__r   typingr   	itertoolsr   httpx r   r5   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%   r8   r   r>   r   r*   r/   r,   <module>r      s    #    "  N M M Q Q ( < [ ; B 7 > fn
%A
o A
HA
# A
H; ;&@ @&A A&F Fr/   