
    Ii                       d dl mZ d dlmZmZmZmZmZ 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mZ ddl 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, ddl-m.Z. ddl/m0Z0m1Z1 ddl2m3Z3m4Z4 ddl5m6Z6m7Z7 ddl8m9Z9m:Z:m;Z; ddl<m=Z=m>Z> ddl?m@Z@ ddlAmBZB ddlCmDZD ddgZE G d de0      ZF G d de1      ZG G d d      ZH G d d      ZI G d d       ZJ G d! d"      ZKy)#    )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)AnthropicBetaParam)BetaManagedAgentsSession)BetaManagedAgentsDeletedSessionSessionsAsyncSessionsc                     e Zd Zedd       Zedd       Zedd       Zedd       Zeeeeeddde	d		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZ
eddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 dd	Zeeeeddde	d
	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeeeeeeeeeeeeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 ddZy)r7   c                ,    t        | j                        S N)r   _clientselfs    q/volume1/homes/robertsu/coba/app/.venv/lib/python3.12/site-packages/anthropic/resources/beta/sessions/sessions.pyeventszSessions.events-   s    dll##    c                ,    t        | j                        S r;   )r"   r<   r=   s    r?   	resourceszSessions.resources1   s    &&rA   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
        )SessionsWithRawResponser=   s    r?   with_raw_responsezSessions.with_raw_response5   s     't,,rA   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
        )SessionsWithStreamingResponser=   s    r?   with_streaming_responsez Sessions.with_streaming_response?   s     -T22rA   N	metadatarC   title	vault_idsbetasextra_headersextra_query
extra_bodytimeoutc               .   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                  dt        ||||||dt        j                        t        ||	|
|      t              S )	>  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  2   K   | ]  }t        |        y wr;   str.0es     r?   	<genexpr>z"Sessions.create.<locals>.<genexpr>y        5Lec!fe   managed-agents-2026-04-01/v1/sessions?beta=trueagentenvironment_idrM   rC   rN   rO   rQ   rR   rS   rT   bodyoptionscast_to)r    r   joinr
   r   _postr   r0   SessionCreateParamsr3   r5   r>   re   rf   rM   rC   rN   rO   rP   rQ   rR   rS   rT   s               r?   createzSessions.createH   s    \	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zz$ "&4 (!*"!* &99
 )+Q[el -!  
 	
rA   rP   rQ   rR   rS   rT   c          
     $   |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

        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 rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z$Sessions.retrieve.<locals>.<genexpr>   r`   ra   rb   #/v1/sessions/{session_id}?beta=true
session_idrg   rj   rk   

ValueErrorr    r   rl   r
   r   _getr   r3   r5   r>   rx   rP   rQ   rR   rS   rT   s          r?   retrievezSessions.retrieve   s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yy?JW(+Q[el -  
 	
rA   rM   rN   rO   rP   rQ   rR   rS   rT   c          
     ^   |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        |||dt        j                        t        ||||		      t        
      S )  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
        rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z"Sessions.update.<locals>.<genexpr>   r`   ra   rb   rv   rw   rM   rN   rO   rg   rh   )r{   r    r   rl   r
   r   rm   r   r   r1   SessionUpdateParamsr3   r5   
r>   rx   rM   rN   rO   rP   rQ   rR   rS   rT   s
             r?   updatezSessions.update   s    L XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zz?JW  ("!*
 &99 )+Q[el -  
 	
rA   agent_idagent_versioncreated_at_gtcreated_at_gtecreated_at_ltcreated_at_lteinclude_archivedlimitmemory_store_idorderpagerP   rQ   rR   rS   rT   c               P   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                  dt        t           t        ||||t        |||||||||	|
|dt        j                              t              S )	Y  
        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.

          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
        rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z Sessions.list.<locals>.<genexpr>E  r`   ra   rb   rc   r   r   r   r   r   r   r   r   r   r   r   rQ   rR   rS   rT   queryr   rj   model)r    r   rl   r
   r   _get_api_listr-   r5   r3   r   r/   SessionListParamsr>   r   r   r   r   r   r   r   r   r   r   r   rP   rQ   rR   rS   rT   s                    r?   listzSessions.list  s    x	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!$ 89(+'%%$,)6)6*8)6*8,<!&+:!& $ (99, +3 " 
 	
rA   c          
     $   |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 )
  
        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
        rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z"Sessions.delete.<locals>.<genexpr>  r`   ra   rb   rv   rw   rg   ry   
r{   r    r   rl   r
   r   _deleter   r3   r6   r}   s          r?   deletezSessions.deletei  s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`||?JW(+Q[el 4  
 	
rA   c          
     $   |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

        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
        rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z#Sessions.archive.<locals>.<genexpr>  r`   ra   rb   +/v1/sessions/{session_id}/archive?beta=truerw   rg   ry   
r{   r    r   rl   r
   r   rm   r   r3   r5   r}   s          r?   archivezSessions.archive  s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zzGT^_(+Q[el -  
 	
rA   )returnr   )r   r"   )r   rF   )r   rJ   re   zsession_create_params.Agentrf   r[   rM   zDict[str, str] | OmitrC   z/Iterable[session_create_params.Resource] | OmitrN   Optional[str] | OmitrO   SequenceNotStr[str] | OmitrP   List[AnthropicBetaParam] | OmitrQ   Headers | NonerR   Query | NonerS   Body | NonerT   'float | httpx.Timeout | None | NotGivenr   r5   rx   r[   rP   r   rQ   r   rR   r   rS   r   rT   r   r   r5   rx   r[   rM   z)Optional[Dict[str, Optional[str]]] | OmitrN   r   rO   r   rP   r   rQ   r   rR   r   rS   r   rT   r   r   r5   )"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   rP   r   rQ   r   rR   r   rS   r   rT   r   r   z(SyncPageCursor[BetaManagedAgentsSession]rx   r[   rP   r   rQ   r   rR   r   rS   r   rT   r   r   r6   __name__
__module____qualname__r(   r@   rC   rG   rK   r   r   rp   r~   r   r   r   r    rA   r?   r7   r7   ,   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15 )-$("&;D)a
 a
 "	a

 3a
 4a
 3a
 4a
 &a
 a
 $a
 -a
 a
 /a
" &#a
$ "%a
&  'a
( 9)a
* 
2+a
N 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
)-
f 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
rA   c                     e Zd Zedd       Zedd       Zedd       Zedd       Zeeeeeddde	d		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZ
eddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 dd	Zeeeeddde	d
	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeeeeeeeeeeeeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 ddZeddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 ddZy)r8   c                ,    t        | j                        S r;   )r   r<   r=   s    r?   r@   zAsyncSessions.events  s    4<<((rA   c                ,    t        | j                        S r;   )r#   r<   r=   s    r?   rC   zAsyncSessions.resources  s    dll++rA   c                    t        |       S rE   )AsyncSessionsWithRawResponser=   s    r?   rG   zAsyncSessions.with_raw_response  s     ,D11rA   c                    t        |       S rI   )"AsyncSessionsWithStreamingResponser=   s    r?   rK   z%AsyncSessions.with_streaming_response  s     2$77rA   NrL   c               ^  K   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                  dt        ||||||dt        j                         d{   t        ||	|
|      t        	       d{   S 7 $7 w)
rV   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z'AsyncSessions.create.<locals>.<genexpr>  r`   ra   rb   rc   rd   Nrg   rh   )r    r   rl   r
   r   rm   r!   r0   rn   r3   r5   ro   s               r?   rp   zAsyncSessions.create  s     \	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZ$,"&4 (!*"!* &99
 
 )+Q[el -!   
 
 	


s$   BB-B)
B-$B+%B-+B-rq   c          
     @  K   |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)rs   rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z)AsyncSessions.retrieve.<locals>.<genexpr>O  r`   ra   rb   rv   rw   rg   ry   Nrz   r}   s          r?   r~   zAsyncSessions.retrieve0  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YY?JW(+Q[el -  
 
 	
 
   BBBBr   c          
       K   |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        |||dt        j                         d	{   t        ||||	
      t               d	{   S 7 $7 w)r   rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z'AsyncSessions.update.<locals>.<genexpr>  r`   ra   rb   rv   rw   r   Nrg   rh   )r{   r    r   rl   r
   r   rm   r   r!   r1   r   r3   r5   r   s
             r?   r   zAsyncSessions.update_  s     L XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZ?JW, ("!*
 &99  )+Q[el -   
 
 	

s$   BCC
C<C=CCr   c               P   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                  dt        t           t        ||||t        |||||||||	|
|dt        j                              t              S )	r   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z%AsyncSessions.list.<locals>.<genexpr>  r`   ra   rb   rc   r   r   r   )r    r   rl   r
   r   r   r.   r5   r3   r   r/   r   r   s                    r?   r   zAsyncSessions.list  s    x	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!$ !9:(+'%%$,)6)6*8)6*8,<!&+:!& $ (99, +3 " 
 	
rA   c          
     @  K   |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   rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z'AsyncSessions.delete.<locals>.<genexpr>$  r`   ra   rb   rv   rw   rg   ry   Nr   r}   s          r?   r   zAsyncSessions.delete  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`\\?JW(+Q[el 4 " 
 
 	
 
r   c          
     @  K   |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   rt   rW   rX   c              3  2   K   | ]  }t        |        y wr;   rZ   r\   s     r?   r_   z(AsyncSessions.archive.<locals>.<genexpr>S  r`   ra   rb   r   rw   rg   ry   Nr   r}   s          r?   r   zAsyncSessions.archive4  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZGT^_(+Q[el -   
 
 	
 
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   rP   r   rQ   r   rR   r   rS   r   rT   r   r   zSAsyncPaginator[BetaManagedAgentsSession, AsyncPageCursor[BetaManagedAgentsSession]]r   r   r   rA   r?   r8   r8     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15 )-$("&;D)a
 a
 "	a

 3a
 4a
 3a
 4a
 &a
 a
 $a
 -a
 a
 /a
" &#a
$ "%a
&  'a
( 9)a
* 
]+a
N 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
)-
f 26 )-$("&;D-
-
 /	-
 &-
 "-
  -
 9-
 
"-
rA   c                  8    e Zd ZddZedd       Zedd       Zy)rF   c                   || _         t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j
                        | _        t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j                        | _        y r;   )		_sessionsr   to_raw_response_wrapperrp   r~   r   r   r   r   r>   sessionss     r?   __init__z SessionsWithRawResponse.__init__e  s    !&>>OO
 )@@
 '>>OO
 %<<MM
	 '>>OO
 (??
rA   c                @    t        | j                  j                        S r;   )r   r   r@   r=   s    r?   r@   zSessionsWithRawResponse.events{  s    $T^^%:%:;;rA   c                @    t        | j                  j                        S r;   )r$   r   rC   r=   s    r?   rC   z!SessionsWithRawResponse.resources  s    '(@(@AArA   Nr   r7   r   None)r   r   )r   r$   r   r   r   r   r(   r@   rC   r   rA   r?   rF   rF   d  s1    
, < < B BrA   rF   c                  8    e Zd ZddZedd       Zedd       Zy)r   c                   || _         t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j
                        | _        t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j                        | _        y r;   )	r   r   async_to_raw_response_wrapperrp   r~   r   r   r   r   r   s     r?   r   z%AsyncSessionsWithRawResponse.__init__  s    !&DDOO
 )FF
 'DDOO
 %BBMM
	 'DDOO
 (EE
rA   c                @    t        | j                  j                        S r;   )r   r   r@   r=   s    r?   r@   z#AsyncSessionsWithRawResponse.events  s    )$..*?*?@@rA   c                @    t        | j                  j                        S r;   )r%   r   rC   r=   s    r?   rC   z&AsyncSessionsWithRawResponse.resources  s    ,T^^-E-EFFrA   Nr   r8   r   r   )r   r   )r   r%   r   r   rA   r?   r   r     s3    
, A A G GrA   r   c                  8    e Zd ZddZedd       Zedd       Zy)rJ   c                J   || _         t        |j                        | _        t        |j                        | _        t        |j                        | _        t        |j
                        | _        t        |j                        | _        t        |j                        | _        y r;   )r   r+   rp   r~   r   r   r   r   r   s     r?   r   z&SessionsWithStreamingResponse.__init__  s    !2OO
 5
 3OO
 1MM
	 3OO
 4
rA   c                @    t        | j                  j                        S r;   )r   r   r@   r=   s    r?   r@   z$SessionsWithStreamingResponse.events  s    *4>>+@+@AArA   c                @    t        | j                  j                        S r;   )r&   r   rC   r=   s    r?   rC   z'SessionsWithStreamingResponse.resources  s    -dnn.F.FGGrA   Nr   )r   r   )r   r&   r   r   rA   r?   rJ   rJ     s3    
, B B H HrA   rJ   c                  8    e Zd ZddZedd       Zedd       Zy)r   c                J   || _         t        |j                        | _        t        |j                        | _        t        |j                        | _        t        |j
                        | _        t        |j                        | _        t        |j                        | _        y r;   )r   r,   rp   r~   r   r   r   r   r   s     r?   r   z+AsyncSessionsWithStreamingResponse.__init__  s    !8OO
 ;
 9OO
 7MM
	 9OO
 :
rA   c                @    t        | j                  j                        S r;   )r   r   r@   r=   s    r?   r@   z)AsyncSessionsWithStreamingResponse.events  s    /0E0EFFrA   c                @    t        | j                  j                        S r;   )r'   r   rC   r=   s    r?   rC   z,AsyncSessionsWithStreamingResponse.resources  s    24>>3K3KLLrA   Nr   )r   r   )r   r'   r   r   rA   r?   r   r     s3    
, G G M MrA   r   )L
__future__r   typingr   r   r   r   r   r	   	itertoolsr
   typing_extensionsr   httpx r   r@   r   r   r   r   r   r   _typesr   r   r   r   r   r   r   r   _utilsr   r   r   r    r!   rC   r"   r#   r$   r%   r&   r'   _compatr(   	_resourcer)   r*   	_responser+   r,   
paginationr-   r.   
types.betar/   r0   r1   _base_clientr2   r3   types.anthropic_beta_paramr4   &types.beta.beta_managed_agents_sessionr5   .types.beta.beta_managed_agents_deleted_sessionr6   __all__r7   r8   rF   r   rJ   r   r   rA   r?   <module>r     s    # 8 8   %  !  ] \ \ g g  ( ; Z : \ \ A = O ^
'Y
 Y
xY
$ Y
xB B@G G@H H@M MrA   