
    _jޞ                       S SK Jr  S SKJrJrJrJrJr  S SKJr  S SK	J
r
  S SKJr  S SKrSSKJ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Jr  SSK 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,  SSK-J.r.  SSK/J0r0J1r1  SSK2J3r3J4r4  SSK5J6r6J7r7  SSK8J9r9J:r:J;r;  SSK<J=r=J>r>  S	SK?J@r@JArAJBrBJCrCJDrDJErE  SSKFJGrG  SSKHJIrI  SSKJJKrK  SS/rL " S S\05      rM " S S\15      rN " S S5      rO " S S5      rP " S  S!5      rQ " S" S#5      rRg)$    )annotations)DictListUnionIterableOptional)datetime)chain)LiteralN   )_legacy_response   )EventsAsyncEventsEventsWithRawResponseAsyncEventsWithRawResponseEventsWithStreamingResponse AsyncEventsWithStreamingResponse)BodyOmitQueryHeadersNotGivenSequenceNotStromit	not_given)is_givenpath_templatemaybe_transformstrip_not_givenasync_maybe_transform)	ResourcesAsyncResourcesResourcesWithRawResponseAsyncResourcesWithRawResponseResourcesWithStreamingResponse#AsyncResourcesWithStreamingResponse)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncPageCursorAsyncPageCursor)session_list_paramssession_create_paramssession_update_params)AsyncPaginatormake_request_options)ThreadsAsyncThreadsThreadsWithRawResponseAsyncThreadsWithRawResponseThreadsWithStreamingResponse!AsyncThreadsWithStreamingResponse)AnthropicBetaParam)BetaManagedAgentsSession)BetaManagedAgentsDeletedSessionSessionsAsyncSessionsc                  "   \ rS rSr\SS j5       r\SS j5       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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=   4   c                ,    [        U R                  5      $ N)r   _clientselfs    _/home/rurouni/.local/lib/python3.13/site-packages/anthropic/resources/beta/sessions/sessions.pyeventsSessions.events5   s    dll##    c                ,    [        U R                  5      $ rB   )r"   rC   rD   s    rF   	resourcesSessions.resources9   s    &&rI   c                ,    [        U R                  5      $ rB   )r4   rC   rD   s    rF   threadsSessions.threads=   s    t||$$rI   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
)SessionsWithRawResponserD   s    rF   with_raw_responseSessions.with_raw_responseA   s     't,,rI   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
)SessionsWithStreamingResponserD   s    rF   with_streaming_response Sessions.with_streaming_responseK   s     -T22rI   N	metadatarK   title	vault_idsbetasextra_headersextra_query
extra_bodytimeoutc               <   0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        UUUUUUS.[        R                  5      [        XXS9[        S9$ )	  Create Session

Args:
  agent: Agent identifier.

Accepts the `agent` ID string, which pins the latest version
      for the session, or an `agent` object with both id and version specified.

  environment_id: ID of the `environment` defining the container configuration for this session.

  metadata: Arbitrary key-value metadata attached to the session. Maximum 16 pairs, keys up
      to 64 chars, values up to 512 chars.

  resources: Resources (e.g. repositories, files) to mount into the session's container.

  title: Human-readable session title.

  vault_ids: Vault IDs for stored credentials the agent can use during the session.

  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
anthropic-beta,c              3  8   #    U  H  n[        U5      v   M     g 7frB   str.0es     rF   	<genexpr>"Sessions.create.<locals>.<genexpr>        5Lec!ffe   managed-agents-2026-04-01/v1/sessions?beta=trueagentenvironment_idr[   rK   r\   r]   r_   r`   ra   rb   bodyoptionscast_to)r    r   joinr
   r   _postr   r0   SessionCreateParamsr3   r;   rE   rt   ru   r[   rK   r\   r]   r^   r_   r`   ra   rb   s               rF   createSessions.createT   s    \	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zz$ "&4 (!*"!* &99
 )+Q[ -!  
 	
rI   r^   r_   r`   ra   rb   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
Q  
Get Session

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 re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   $Sessions.retrieve.<locals>.<genexpr>   ro   rp   rq   #/v1/sessions/{session_id}?beta=true
session_idrv   ry   rz   

ValueErrorr    r   r{   r
   r   _getr   r3   r;   rE   r   r^   r_   r`   ra   rb   s          rF   retrieveSessions.retrieve   s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yy?JW(+Q[ -  
 	
rI   r[   r\   r]   r^   r_   r`   ra   rb   c               r   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUS.[        R                  5      [        XgXS	9[        S
9$ )  Update Session

Args:
  metadata: Metadata patch.

Set a key to a string to upsert it, or to null to delete it.
      Omit the field to preserve.

  title: Human-readable session title.

  vault_ids: Vault IDs (`vlt_*`) to attach to the session. Not yet supported; requests
      setting this field are rejected. Reserved for future use.

  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
r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   "Sessions.update.<locals>.<genexpr>   ro   rp   rq   r   r   r[   r\   r]   rv   rw   )r   r    r   r{   r
   r   r|   r   r   r1   SessionUpdateParamsr3   r;   
rE   r   r[   r\   r]   r^   r_   r`   ra   rb   s
             rF   updateSessions.update   s    L XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zz?JW  ("!*
 &99 )+Q[ -  
 	
rI   agent_idagent_versioncreated_at_gtcreated_at_gtecreated_at_ltcreated_at_lteinclude_archivedlimitmemory_store_idorderpagestatusesr^   r_   r`   ra   rb   c               d   0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        [           [        UUUU[        UUUUUUUUU	U
UUS.[        R                  5      S9[        S9$ )	  
List Sessions

Args:
  agent_id: Filter sessions created with this agent ID.

  agent_version: Filter by agent version. Only applies when agent_id is also set.

  created_at_gt: Return sessions created after this time (exclusive).

  created_at_gte: Return sessions created at or after this time (inclusive).

  created_at_lt: Return sessions created before this time (exclusive).

  created_at_lte: Return sessions created at or before this time (inclusive).

  include_archived: When true, includes archived sessions. Default: false (exclude archived).

  limit: Maximum number of results to return.

  memory_store_id: Filter sessions whose resources contain a memory_store with this memory store
      ID.

  order: Sort direction for results, ordered by created_at. Defaults to desc (newest
      first).

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

  statuses: Filter by session status. Repeat the parameter to match any of multiple
      statuses.

  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
re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm    Sessions.list.<locals>.<genexpr>U  ro   rp   rq   rr   r   r   r   r   r   r   r   r   r   r   r   r   r_   r`   ra   rb   queryr   ry   model)r    r   r{   r
   r   _get_api_listr-   r;   r3   r   r/   SessionListParamsrE   r   r   r   r   r   r   r   r   r   r   r   r   r^   r_   r`   ra   rb   s                     rF   listSessions.list  s    @	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!$ 89(+'%%$,)6)6*8)6*8,<!&+:!& $$, (99. +5 " 
 	
rI   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
T  
Delete Session

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
r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   "Sessions.delete.<locals>.<genexpr>  ro   rp   rq   r   r   rv   r   
r   r    r   r{   r
   r   _deleter   r3   r<   r   s          rF   deleteSessions.deletez  s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`||?JW(+Q[ 4  
 	
rI   c          
     8   U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9$ )
U  
Archive Session

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
r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   #Sessions.archive.<locals>.<genexpr>  ro   rp   rq   +/v1/sessions/{session_id}/archive?beta=truer   rv   r   
r   r    r   r{   r
   r   r|   r   r3   r;   r   s          rF   archiveSessions.archive  s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zzGT^_(+Q[ -  
 	
rI    )returnr   )r   r"   )r   r4   )r   rR   )r   rW   rt   zsession_create_params.Agentru   ri   r[   zDict[str, str] | OmitrK   z/Iterable[session_create_params.Resource] | Omitr\   Optional[str] | Omitr]   SequenceNotStr[str] | Omitr^   List[AnthropicBetaParam] | Omitr_   Headers | Noner`   Query | Nonera   Body | Nonerb   'float | httpx.Timeout | None | NotGivenr   r;   r   ri   r^   r   r_   r   r`   r   ra   r   rb   r   r   r;   r   ri   r[   z)Optional[Dict[str, Optional[str]]] | Omitr\   r   r]   r   r^   r   r_   r   r`   r   ra   r   rb   r   r   r;   )$r   
str | Omitr   
int | Omitr   Union[str, datetime] | Omitr   r   r   r   r   r   r   bool | Omitr   r   r   r   r   Literal['asc', 'desc'] | Omitr   r   r   EList[Literal['rescheduling', 'running', 'idle', 'terminated']] | Omitr^   r   r_   r   r`   r   ra   r   rb   r   r   z(SyncPageCursor[BetaManagedAgentsSession]r   ri   r^   r   r_   r   r`   r   ra   r   rb   r   r   r<   __name__
__module____qualname____firstlineno__r(   rG   rK   rN   rS   rX   r   r   r   r   r   r   r   r   __static_attributes__r   rI   rF   r=   r=   4   s   $ $ ' ' % % - - 3 3 +/EI&*0415 )-$("&;DJ
 +J
 	J

 (J
 CJ
 $J
 .J
 /J
 &J
 "J
  J
 9J
  
"!J
` 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
f ?C&*0415 )-$("&;DA
A
 <	A

 $A
 .A
 /A
 &A
 "A
  A
 9A
 
"A
L  $$(596:596:(, &*/3Z^15 )-$("&;D+f
 f
 "	f

 3f
 4f
 3f
 4f
 &f
 f
 $f
 -f
 f
 Xf
 /f
$ &%f
& "'f
(  )f
* 9+f
, 
2-f
X 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
)-
f 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
 -
rI   c                  "   \ rS rSr\SS j5       r\SS j5       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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>   i  c                ,    [        U R                  5      $ rB   )r   rC   rD   s    rF   rG   AsyncSessions.events  s    4<<((rI   c                ,    [        U R                  5      $ rB   )r#   rC   rD   s    rF   rK   AsyncSessions.resources  s    dll++rI   c                ,    [        U R                  5      $ rB   )r5   rC   rD   s    rF   rN   AsyncSessions.threads  s    DLL))rI   c                    [        U 5      $ rQ   )AsyncSessionsWithRawResponserD   s    rF   rS   AsyncSessions.with_raw_response  s     ,D11rI   c                    [        U 5      $ rV   )"AsyncSessionsWithStreamingResponserD   s    rF   rX   %AsyncSessions.with_streaming_response  s     2$77rI   NrZ   c               l  #    0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        UUUUUUS.[        R                  5      I Sh  vN [        XXS9[        S	9I Sh  vN $  N N7f)
rd   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   'AsyncSessions.create.<locals>.<genexpr>*  ro   rp   rq   rr   rs   Nrv   rw   )r    r   r{   r
   r   r|   r!   r0   r}   r3   r;   r~   s               rF   r   AsyncSessions.create  s     \	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZ$,"&4 (!*"!* &99
 
 )+Q[ -!   
 
 	


s$   BB4B0
B4+B2,B42B4r   c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r   r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   )AsyncSessions.retrieve.<locals>.<genexpr>d  ro   rp   rq   r   r   rv   r   Nr   r   s          rF   r   AsyncSessions.retrieveE  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YY?JW(+Q[ -  
 
 	
 
   BB(!B&"B(r   c                 #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUS.[        R                  5      I S	h  vN [        XgXS
9[        S9I S	h  vN $  N N7f)r   r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   'AsyncSessions.update.<locals>.<genexpr>  ro   rp   rq   r   r   r   Nrv   rw   )r   r    r   r{   r
   r   r|   r   r!   r1   r   r3   r;   r   s
             rF   r   AsyncSessions.updatet  s     L XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZ?JW, ("!*
 &99  )+Q[ -   
 
 	

s$   B,C.C
/CCCCr   c               d   0 [        S[        U5      (       a#  SR                  [        S U 5       S/5      5      O[        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  S[        [           [        UUUU[        UUUUUUUUU	U
UUS.[        R                  5      S9[        S9$ )	r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   %AsyncSessions.list.<locals>.<genexpr>  ro   rp   rq   rr   r   r   r   )r    r   r{   r
   r   r   r.   r;   r3   r   r/   r   r   s                     rF   r   AsyncSessions.list  s    @	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!$ !9:(+'%%$,)6)6*8)6*8,<!&+:!& $$, (99. +5 " 
 	
rI   c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r   r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   'AsyncSessions.delete.<locals>.<genexpr>>  ro   rp   rq   r   r   rv   r   Nr   r   s          rF   r   AsyncSessions.delete  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`\\?JW(+Q[ 4 " 
 
 	
 
r   c          
     T  #    U(       d  [        SU< 35      e0 [        S[        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        05      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        X4XVS9[        S	9I S
h  vN $  N7f)r   r   re   rf   c              3  8   #    U  H  n[        U5      v   M     g 7frB   rh   rj   s     rF   rm   (AsyncSessions.archive.<locals>.<genexpr>m  ro   rp   rq   r   r   rv   r   Nr   r   s          rF   r   AsyncSessions.archiveN  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZGT^_(+Q[ -   
 
 	
 
r   r   )r   r   )r   r#   )r   r5   )r   r   )r   r   r   r   r   )$r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r^   r   r_   r   r`   r   ra   r   rb   r   r   zSAsyncPaginator[BetaManagedAgentsSession, AsyncPageCursor[BetaManagedAgentsSession]]r   r   r   rI   rF   r>   r>     s   ) ) , , * * 2 2 8 8 +/EI&*0415 )-$("&;DJ
 +J
 	J

 (J
 CJ
 $J
 .J
 /J
 &J
 "J
  J
 9J
  
"!J
` 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
f ?C&*0415 )-$("&;DA
A
 <	A

 $A
 .A
 /A
 &A
 "A
  A
 9A
 
"A
L  $$(596:596:(, &*/3Z^15 )-$("&;D+f
 f
 "	f

 3f
 4f
 3f
 4f
 &f
 f
 $f
 -f
 f
 Xf
 /f
$ &%f
& "'f
(  )f
* 9+f
, 
]-f
X 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
)-
f 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
 -
rI   c                  Z    \ rS rSrSS jr\S	S j5       r\S
S j5       r\SS j5       rSr	g)rR   i~  c                   Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g rB   )		_sessionsr   to_raw_response_wrapperr   r   r   r   r   r   rE   sessionss     rF   __init__ SessionsWithRawResponse.__init__  s    !&>>OO
 )@@
 '>>OO
 %<<MM
	 '>>OO
 (??
rI   c                @    [        U R                  R                  5      $ rB   )r   r  rG   rD   s    rF   rG   SessionsWithRawResponse.events  s    $T^^%:%:;;rI   c                @    [        U R                  R                  5      $ rB   )r$   r  rK   rD   s    rF   rK   !SessionsWithRawResponse.resources  s    '(@(@AArI   c                @    [        U R                  R                  5      $ rB   )r6   r  rN   rD   s    rF   rN   SessionsWithRawResponse.threads  s    %dnn&<&<==rI   r  r   r   r   r   r   r   Nr
  r=   r   None)r   r   )r   r$   )r   r6   
r   r   r   r   r  r(   rG   rK   rN   r   r   rI   rF   rR   rR   ~  sE    
, < < B B > >rI   rR   c                  Z    \ rS rSrSS jr\S	S j5       r\S
S j5       r\SS j5       rSr	g)r   i  c                   Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR
                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g rB   )	r  r   async_to_raw_response_wrapperr   r   r   r   r   r   r	  s     rF   r  %AsyncSessionsWithRawResponse.__init__  s    !&DDOO
 )FF
 'DDOO
 %BBMM
	 'DDOO
 (EE
rI   c                @    [        U R                  R                  5      $ rB   )r   r  rG   rD   s    rF   rG   #AsyncSessionsWithRawResponse.events  s    )$..*?*?@@rI   c                @    [        U R                  R                  5      $ rB   )r%   r  rK   rD   s    rF   rK   &AsyncSessionsWithRawResponse.resources  s    ,T^^-E-EFFrI   c                @    [        U R                  R                  5      $ rB   )r7   r  rN   rD   s    rF   rN   $AsyncSessionsWithRawResponse.threads  s    *4>>+A+ABBrI   r  Nr
  r>   r   r  )r   r   )r   r%   )r   r7   r  r   rI   rF   r   r     sI    
, A A G G C CrI   r   c                  Z    \ rS rSrSS jr\S	S j5       r\S
S j5       r\SS j5       rSr	g)rW   i  c                H   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rB   )r  r+   r   r   r   r   r   r   r	  s     rF   r  &SessionsWithStreamingResponse.__init__  s    !2OO
 5
 3OO
 1MM
	 3OO
 4
rI   c                @    [        U R                  R                  5      $ rB   )r   r  rG   rD   s    rF   rG   $SessionsWithStreamingResponse.events  s    *4>>+@+@AArI   c                @    [        U R                  R                  5      $ rB   )r&   r  rK   rD   s    rF   rK   'SessionsWithStreamingResponse.resources  s    -dnn.F.FGGrI   c                @    [        U R                  R                  5      $ rB   )r8   r  rN   rD   s    rF   rN   %SessionsWithStreamingResponse.threads  s    +DNN,B,BCCrI   r  Nr  )r   r   )r   r&   )r   r8   r  r   rI   rF   rW   rW     sI    
, B B H H D DrI   rW   c                  Z    \ rS rSrSS jr\S	S j5       r\S
S j5       r\SS j5       rSr	g)r   i  c                H   Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        [        UR
                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rB   )r  r,   r   r   r   r   r   r   r	  s     rF   r  +AsyncSessionsWithStreamingResponse.__init__  s    !8OO
 ;
 9OO
 7MM
	 9OO
 :
rI   c                @    [        U R                  R                  5      $ rB   )r   r  rG   rD   s    rF   rG   )AsyncSessionsWithStreamingResponse.events  s    /0E0EFFrI   c                @    [        U R                  R                  5      $ rB   )r'   r  rK   rD   s    rF   rK   ,AsyncSessionsWithStreamingResponse.resources  s    24>>3K3KLLrI   c                @    [        U R                  R                  5      $ rB   )r9   r  rN   rD   s    rF   rN   *AsyncSessionsWithStreamingResponse.threads	  s    01G1GHHrI   r  Nr!  )r   r   )r   r'   )r   r9   r  r   rI   rF   r   r     sI    
, G G M M I IrI   r   )S
__future__r   typingr   r   r   r   r   r	   	itertoolsr
   typing_extensionsr   httpx r   rG   r   r   r   r   r   r   _typesr   r   r   r   r   r   r   r   _utilsr   r   r   r    r!   rK   r"   r#   r$   r%   r&   r'   _compatr(   	_resourcer)   r*   	_responser+   r,   
paginationr-   r.   
types.betar/   r0   r1   _base_clientr2   r3   threads.threadsr4   r5   r6   r7   r8   r9   types.anthropic_beta_paramr:   &types.beta.beta_managed_agents_sessionr;   .types.beta.beta_managed_agents_deleted_sessionr<   __all__r=   r>   rR   r   rW   r   r   rI   rF   <module>rG     s    # 8 8   %  !  ] \ \ g g  ( ; Z : \ \ A  > O ^
'b
 b
Jb
$ b
J!> !>H!C !CH!D !DH!I !IrI   