
    Ii                    0   d dl mZ d dlZd dlmZmZmZ d dlmZm	Z	 d dl
Z
ddlmZmZ ddl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 dd
lmZ ddlm Z  ddl!m"Z"m#Z# ddlm$Z$ ddl%m&Z&m'Z'm(Z( ddl)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1m2Z2 ddl3m4Z4 d)dZ5d*dZ6d+dZ7d,dZ8d-dZ9er,ddl:m;Z;m<Z<m=Z=m>Z> ddl?m@Z@mAZA ddlBmCZCmDZD ddlEmFZFmGZG ddlHmIZImJZJ g dZK G d de'      ZL G d d e(      ZM G d! d"      ZN G d# d$      ZO G d% d&      ZP G d' d(      ZQeLZReMZSy).    )annotationsN)TYPE_CHECKINGAnyMapping)Selfoverride   )
_constants_exceptionsQuerystring)OmitHeadersTimeoutNotGiven	TransportProxiesTypesRequestOptions	not_given)is_givenis_mapping_tget_async_library)cached_property)__version__)StreamAsyncStream)APIStatusError)DEFAULT_MAX_RETRIESSyncAPIClientAsyncAPIClient)
TokenCacheInMemoryConfigAccessTokenAuthCredentialsFileAccessTokenProviderdefault_credentials)&warn_env_static_shadows_auto_discovery(warn_explicit_static_shadows_credentials)"_has_auto_discoverable_credentialsc                0    t        |       t        t        fv S )a0  True only for the base ``Anthropic`` / ``AsyncAnthropic`` classes, not subclasses.

    Subclasses (``AnthropicAWS``, ``AnthropicFoundry``) have their own auth paths
    and must not run the credential chain or forward ``credentials`` through their
    ``__init__`` (which doesn't accept the kwarg).
    )type	AnthropicAsyncAnthropic)clients    X/volume1/homes/robertsu/coba/app/.venv/lib/python3.12/site-packages/anthropic/_client.py_is_base_clientr0   6   s     <I~666    c                2    t        | dd      }| |        yy)zPRelease any resources owned by a credential provider, if it exposes ``close()``.closeN)getattr)credentialsr3   s     r/   _close_credentialsr6   @   s     K$/E r1   c                F    t        | dd      }t        |      r	 ||       yy)u  If the credential provider supports ``bind_base_url``, pass it the
    client's resolved ``base_url`` so the token exchange and API calls hit
    the same deployment without the caller passing the URL twice.

    Providers without the hook (plain callables, custom impls) are left
    untouched and MUST resolve their own token-exchange ``base_url`` — the
    client does not second-guess them.
    bind_base_urlN)r4   callable)r5   base_urlbinds      r/   _bind_credentials_base_urlr<   G   s%     ;6D~X r1   c                @    |y| t        d       |t        d       yy)zWarn when an explicit ``api_key=`` / ``auth_token=`` argument shadows
    an explicit ``credentials=`` provider. Call *after* any copy-inheritance
    merging so the params reflect the resolved values.Napi_key
auth_token)r(   r>   r?   r5   s      r/   _warn_explicit_shadowrA   U   s.     0;0> r1   c                    t               sy| *t        j                  j                  d      rt	        d       |,t        j                  j                  d      rt	        d       yyy)av  Warn when an ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` from the
    environment is set alongside signals that would normally drive profile /
    federation auto-discovery (``ANTHROPIC_PROFILE``, a ``configs/`` directory,
    or the workload-identity env trio). Per the credential-precedence spec,
    the static credential wins and auto-discovery is silently skipped.NANTHROPIC_API_KEYANTHROPIC_AUTH_TOKEN)r)   osenvirongetr'   r>   r?   s     r/   _warn_env_shadowrI   a   sT     ./rzz~~.AB./BC"**..1G"H./EF #Ir1   )betamodelsmessagescompletions)ModelsAsyncModels)Beta	AsyncBeta)CompletionsAsyncCompletions)MessagesAsyncMessages)r   r   r   r   r,   r-   ClientAsyncClientc                      e Zd ZU ded<   ded<   ded<   ded<   ded	<   ej
                  Zej                  Zd
d
d
d
d
d
eed
d
d
ded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d  fdZ	e
d!d       Ze
d"d       Ze
d#d       Ze
d$d       Ze
d%d       Ze
d&d       Zeed'd              Zeed(d              Zed(d       Zed(d       Zeed) fd              Zed*d       Zeed+d              Zed, fd       Zed- fd       Zd
d
ed
d
d
ed
ed
d
d
d
i d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d.dZeZe	 	 	 	 	 	 	 	 d/d       Z xZS )0r,   
str | Noner>   r?   AccessTokenProvider | Noner5   TokenCache | None_token_cacheAccessTokenAuth | None_custom_authNFr>   r?   r5   configprofiler:   timeoutmax_retriesdefault_headersdefault_queryhttp_client_strict_response_validationr\   c          
        |duxs |duxs |duxs
 |duxs |du}|s>t         j                  j                  d      }t         j                  j                  d      }|| _        || _        |t         j                  j                  d      }|du}|d}t         j                  j                  d      }|li }|j                  d      D ]C  }|j                  d      }|d	k\  s||d
z   d j                         ||d| j                         <   E i |t        |	      r|	ni }	i }|P||t        d      t        t        |            }|}|j                         }|s`|j                  rT|j                  }nG|E|t        d      t        |      }|}|j                         }|s|j                  r|j                  }|\|Z|Xt        |       rMt!        |rt#        |      nd      }|2|j$                  }|j                  }|s|j&                  r|j&                  }t)        |t#        |             || _        t-        |||       t/        ||       t1        |t2              s|| _        n|t7        |      nd| _        | j4                  t9        | j4                        nd| _        |r
i ||	xs i }	t<        | }  t@        |||||	|
|       tB        | _"        y)ud  Construct a new synchronous Anthropic client instance.

        Credentials are resolved in the following order (first match wins):

        1. Explicit constructor arguments — ``api_key=``, ``auth_token=``,
           ``credentials=``, ``config=``, or ``profile=``. When any of these
           is passed, environment variables are not consulted for credentials.
        2. ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` environment
           variables.
        3. ``ANTHROPIC_PROFILE`` environment variable — loads the named
           profile from ``<config_dir>/configs/<profile>.json``.
        4. Workload identity federation environment variables —
           ``ANTHROPIC_IDENTITY_TOKEN[_FILE]`` +
           ``ANTHROPIC_FEDERATION_RULE_ID`` + ``ANTHROPIC_ORGANIZATION_ID``.
        5. The active profile on disk — the profile named by
           ``<config_dir>/active_config``, or ``default``.

        ``credentials=``, ``config=``, and ``profile=`` are mutually exclusive.

        If a static credential is supplied alongside a credentials provider
        (``credentials=`` / ``config=`` / ``profile=``), or if
        ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` is set alongside a
        profile or federation configuration, the static credential takes
        precedence and a one-shot warning is logged on the ``anthropic``
        logger.
        NrC   rD   ANTHROPIC_BASE_URLhttps://api.anthropic.comANTHROPIC_CUSTOM_HEADERS
:r   r	   =Pass at most one of `credentials=`, `config=`, or `profile=`.ra   r:   r@   rH   versionr:   rc   rb   rf   custom_headerscustom_queryrg   )#rE   rF   rG   r>   r?   splitfindstripr   	TypeErrorr"   dictextra_headersresolved_base_urlr$   r0   r&   strproviderr:   r<   r5   rA   rI   
isinstancer   r\   r!   r#   r^   super__init__r   r   _default_stream_clsselfr>   r?   r5   r`   ra   r:   rb   rc   rd   re   rf   rg   r\   has_explicit_credentialbase_url_is_explicitcustom_headers_envparsedlinecoloncredential_headers	in_memory
creds_fileresult	__class__s                           r/   r   zAnthropic.__init__   s   t 4 #%#$&# T!# d" 	  'jjnn%89G(>?J$ zz~~&:;H
  (t32HZZ^^,FG)%'F*006		#A:37	3D3J3J3LF4<--/0 7 gf|O?\ObdfO .0&'*= _``&tF|4I#K!*!8!8!:'I,G,G$66 & _``(9J$K!+!9!9!;'J,H,H%777?z7Io^bNc(8#h-QlmF!$oo%+%9%9"+%H";H>&g*R]^Z@,1 ,D;F;R
; 7X\DBFBSBSB_OD,=,=>eiO!3O8M2OO 	##*&(C 	 		
 $* r1   c                    ddl m}  ||       S )Nr	   )rR   )resources.completionsrR   )r   rR   s     r/   rM   zAnthropic.completions  s    64  r1   c                    ddl m}  ||       S )Nr	   )rT   )resources.messagesrT   )r   rT   s     r/   rL   zAnthropic.messages#  s    0~r1   c                    ddl m}  ||       S )Nr	   )rN   )resources.modelsrN   )r   rN   s     r/   rK   zAnthropic.models)  s    ,d|r1   c                    ddl m}  ||       S )Nr	   )rP   )resources.betarP   )r   rP   s     r/   rJ   zAnthropic.beta/  s    (Dzr1   c                    t        |       S N)AnthropicWithRawResponser   s    r/   with_raw_responsezAnthropic.with_raw_response5  s    '--r1   c                    t        |       S r   )AnthropicWithStreamedResponser   s    r/   with_streaming_responsez!Anthropic.with_streaming_response9      ,T22r1   c                    t        d      S Ncomma)array_formatr   r   s    r/   qszAnthropic.qs=       00r1   c                6    i | j                   | j                  S r   _api_key_auth_bearer_authr   s    r/   auth_headerszAnthropic.auth_headersB        ;$$$:(9(9::r1   c                *    | j                   }|i S d|iS N	X-Api-Keyr>   r   r>   s     r/   r   zAnthropic._api_key_authG       ,,?IW%%r1   c                0    | j                   }|i S dd| iS NAuthorizationzBearer r?   r   r?   s     r/   r   zAnthropic._bearer_authN  *     __
I7:,!788r1   c                >    i t         |   ddd| j                  S )Nfalse
2023-06-01zX-Stainless-Asynczanthropic-version)r   rd   _custom_headersr   r   s    r/   rd   zAnthropic.default_headers[  s5    
g%
!(!-
 ""	
 	
r1   c                   | j                   #|j                  d      s|j                  d      sy |j                  d      s|j                  d      ry |j                  d      st        |j                  d      t              ry |j                  d      st        |j                  d      t              ry t	        d      Nr   r   z"Could not resolve authentication method. Expected one of api_key, auth_token, or credentials to be set. Or for one of the `X-Api-Key` or `Authorization` headers to be explicitly omitted"r\   rG   r~   r   rx   r   headersrs   s      r/   _validate_headerszAnthropic._validate_headerse  s     ([1IRYR]R]^mRn;;'7;;{+C;;{#z.2D2D[2QSW'X;;':n6H6H6Y[_+` J
 	
r1   c                    | j                   S r   r^   r   s    r/   custom_authzAnthropic.custom_auth          r1   c                    |j                   dk(  rO| j                  C| j                  j                          |j                  j                  j                  d      dk(  ryt        |   |      S N  zx-stainless-retry-count0Tstatus_coder\   
invalidaterequestr   rG   r   _should_retryr   responser   s     r/   r   zAnthropic._should_retry  c     3&4+<+<+H((*''++,EF#Mw$X..r1   c                L    t         |           t        | j                         y r   r   r3   r6   r5   r   s    r/   r3   zAnthropic.close  s    4++,r1   r>   r?   r5   r`   ra   r:   rb   rf   rc   rd   set_default_headersre   set_default_query_extra_kwargsc                  |
|t        d      ||t        d      | j                  }|
i ||
}n||}| j                  }|i ||}n||}|xs | j                  }|$t	        |t
              r|t        d      d|i|}nu|"t	        |t
              st        d      d|i|}nQt	        |t
              r| j                  n|}|1t        |       r&d|i|}t	        |t
              rd| j                  i|} | j                  d	|xs | j                  |xs | j                  |xs | j                  t	        |t
              r| j                  n||t        |	      r|	n| j                   ||d|S 
z~
        Create a new client instance re-using the same options given to the current client with optional overriding.
        zPThe `default_headers` and `set_default_headers` arguments are mutually exclusivezLThe `default_query` and `set_default_query` arguments are mutually exclusivern   r`   ra   r5   r\   )r>   r?   r:   rb   rf   rc   rd   re    
ValueErrorr   _custom_query_clientr~   r   rx   r5   r0   r\   r   r>   r?   r:   rb   r   rc   r   r>   r?   r5   r`   ra   r:   rb   rf   rc   rd   r   re   r   r   r   paramsresolved_credentialss                     r/   copyzAnthropic.copy     * &+>+Jopp$):)Fkll&&&44O4G ,)G##$00-0F*&F!1T\\k848K _``%v??M k84 _``&A=AM7A+x7X4#3#3^i #/OD4I!.0D V V k84%3T5F5F$X-$XMt~~ 

+t||!4T__.$.w$ADLLw#'/'<$BRBR# 

 

 
	
r1   c               *   |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j
                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   d	k(  rt        j                  |||      S |j                   d
k(  rt        j                  |||      S |j                   dk\  rt        j                  |||      S t        |||      S Ni  )r   bodyr   i  i  i  i  i  i  i  i  r   r   BadRequestErrorAuthenticationErrorPermissionDeniedErrorNotFoundErrorConflictErrorRequestTooLargeErrorUnprocessableEntityErrorRateLimitErrorOverloadedErrorInternalServerErrorr   r   err_msgr   r   s       r/   _make_status_errorzAnthropic._make_status_error  x    3&..wPTUU3&227XTXYY3&44WxVZ[[3&,,WxdSS3&,,WxdSS3&33GhUYZZ3&77(Y]^^3&--gtTT3&..wPTUU3&227XTXYYgtDDr1   )r>   rY   r?   rY   r5   rZ   r`   Mapping[str, Any] | Nonera   rY   r:   str | httpx.URL | Nonerb   !float | Timeout | None | NotGivenrc   intrd   Mapping[str, str] | Nonere   Mapping[str, object] | Nonerf   httpx.Client | Nonerg   boolr\   TokenCache | None | NotGivenreturnNone)r  rR   )r  rT   )r  rN   )r  rP   )r  r   )r  r   r  r   r  zdict[str, str]r  zdict[str, str | Omit]r   r   rs   r   r  r  r  zhttpx.Auth | Noner   httpx.Responser  r   r  r  )r>   rY   r?   rY   r5   %AccessTokenProvider | None | NotGivenr`   r   ra   rY   r:   r   rb   r   rf   r   rc   int | NotGivenrd   r   r   r   re   r   r   r   r   Mapping[str, Any]r  r   r   r|   r   objectr   r	  r  r    __name__
__module____qualname____annotations__r
   HUMAN_PROMPT	AI_PROMPTr   r   r   r   rM   rL   rK   rJ   r   r   propertyr   r   r   r   r   rd   r   r   r   r3   r   with_optionsr   __classcell__r   s   @r/   r,   r,      sp   ++##(( **L$$I
 #!%26+/"+/5>.4859 ,0 -25>5K* K* 	K*
 0K* )K* K* )K* 3K* K* 2K* 3K*  )!K*2 &*3K*4 35K*6 
7K*Z ! !
  
  
  
 . . 3 3 1  1 ;  ; & & 
9 
9 
  
 
 
4 !  ! / / - - #!%=F+/"+/5>+/&/488<599=+-!E
 E
 	E

 ;E
 )E
 E
 )E
 3E
 )E
 $E
 2E
 6E
 3E
 7E
  )!E
" 
#E
R L$E$E 	$E
 !$E 
$E $Er1   r,   c                      e Zd ZU ded<   ded<   ded<   ded<   ded	<   ej
                  Zej                  Zd
d
d
d
d
d
eed
d
d
ded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d  fdZ	e
d!d       Ze
d"d       Ze
d#d       Ze
d$d       Ze
d%d       Ze
d&d       Zeed'd              Zeed(d              Zed(d       Zed(d       Zeed) fd              Zed*d       Zeed+d              Zed, fd       Zed- fd       Zd
d
ed
d
d
ed
ed
d
d
d
i d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d.dZeZe	 	 	 	 	 	 	 	 d/d       Z xZS )0r-   rY   r>   r?   rZ   r5   r[   r\   r]   r^   NFr_   c          
        |duxs |duxs |duxs
 |duxs |du}|s>t         j                  j                  d      }t         j                  j                  d      }|| _        || _        |t         j                  j                  d      }|du}|d}t         j                  j                  d      }|li }|j                  d      D ]C  }|j                  d      }|d	k\  s||d
z   d j                         ||d| j                         <   E i |t        |	      r|	ni }	i }|P||t        d      t        t        |            }|}|j                         }|s`|j                  rT|j                  }nG|E|t        d      t        |      }|}|j                         }|s|j                  r|j                  }|\|Z|Xt        |       rMt!        |rt#        |      nd      }|2|j$                  }|j                  }|s|j&                  r|j&                  }t)        |t#        |             || _        t-        |||       t/        ||       t1        |t2              s|| _        n|t7        |      nd| _        | j4                  t9        | j4                        nd| _        |r
i ||	xs i }	t<        | }  t@        |||||	|
|       tB        | _"        y)uc  Construct a new async AsyncAnthropic client instance.

        Credentials are resolved in the following order (first match wins):

        1. Explicit constructor arguments — ``api_key=``, ``auth_token=``,
           ``credentials=``, ``config=``, or ``profile=``. When any of these
           is passed, environment variables are not consulted for credentials.
        2. ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` environment
           variables.
        3. ``ANTHROPIC_PROFILE`` environment variable — loads the named
           profile from ``<config_dir>/configs/<profile>.json``.
        4. Workload identity federation environment variables —
           ``ANTHROPIC_IDENTITY_TOKEN[_FILE]`` +
           ``ANTHROPIC_FEDERATION_RULE_ID`` + ``ANTHROPIC_ORGANIZATION_ID``.
        5. The active profile on disk — the profile named by
           ``<config_dir>/active_config``, or ``default``.

        ``credentials=``, ``config=``, and ``profile=`` are mutually exclusive.

        If a static credential is supplied alongside a credentials provider
        (``credentials=`` / ``config=`` / ``profile=``), or if
        ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` is set alongside a
        profile or federation configuration, the static credential takes
        precedence and a one-shot warning is logged on the ``anthropic``
        logger.
        NrC   rD   ri   rj   rk   rl   rm   r   r	   rn   ro   rp   r@   rH   rq   )#rE   rF   rG   r>   r?   ru   rv   rw   r   rx   r"   ry   rz   r{   r$   r0   r&   r|   r}   r:   r<   r5   rA   rI   r~   r   r\   r!   r#   r^   r   r   r   r   r   r   s                           r/   r   zAsyncAnthropic.__init__  s   t 4 #%#$&# T!# d" 	  'jjnn%89G(>?J$ zz~~&:;H
  (t32HZZ^^,FG)%'F*006		#A:37	3D3J3J3LF4<--/0 7 gf|O?\ObdfO .0&'*= _``&tF|4I#K!*!8!8!:'I,G,G$66 & _``(9J$K!+!9!9!;'J,H,H%777?z7Io^bNc(8#h-QlmF!$oo%+%9%9"+%H";H>&g*R]^Z@,1 ,D;F;R
; 7X\DBFBSBSB_OD,=,=>eiO!3O8M2OO 	##*&(C 	 		
 $/ r1   c                    ddl m}  ||       S )Nr	   )rS   )r   rS   )r   rS   s     r/   rM   zAsyncAnthropic.completions  s    ;%%r1   c                    ddl m}  ||       S )Nr	   )rU   )r   rU   )r   rU   s     r/   rL   zAsyncAnthropic.messages  s    5T""r1   c                    ddl m}  ||       S )Nr	   )rO   )r   rO   )r   rO   s     r/   rK   zAsyncAnthropic.models  s    14  r1   c                    ddl m}  ||       S )Nr	   )rQ   )r   rQ   )r   rQ   s     r/   rJ   zAsyncAnthropic.beta  s    -r1   c                    t        |       S r   )AsyncAnthropicWithRawResponser   s    r/   r   z AsyncAnthropic.with_raw_response  r   r1   c                    t        |       S r   )"AsyncAnthropicWithStreamedResponser   s    r/   r   z&AsyncAnthropic.with_streaming_response  s    1$77r1   c                    t        d      S r   r   r   s    r/   r   zAsyncAnthropic.qs  r   r1   c                6    i | j                   | j                  S r   r   r   s    r/   r   zAsyncAnthropic.auth_headers  r   r1   c                *    | j                   }|i S d|iS r   r   r   s     r/   r   zAsyncAnthropic._api_key_auth  r   r1   c                0    | j                   }|i S dd| iS r   r   r   s     r/   r   zAsyncAnthropic._bearer_auth  r   r1   c                T    i t         |   dt                dd| j                  S )Nzasync:r   r   )r   rd   r   r   r   s    r/   rd   zAsyncAnthropic.default_headers  sA    
g%
#)*;*=)>!?!-
 ""	
 	
r1   c                   | j                   #|j                  d      s|j                  d      sy |j                  d      s|j                  d      ry |j                  d      st        |j                  d      t              ry |j                  d      st        |j                  d      t              ry t	        d      r   r   r   s      r/   r   z AsyncAnthropic._validate_headers  s     ([1IRYR]R]^mRn;;'7;;{+C;;{#z.2D2D[2QSW'X;;':n6H6H6Y[_+` J
 	
r1   c                    | j                   S r   r   r   s    r/   r   zAsyncAnthropic.custom_auth  r   r1   c                    |j                   dk(  rO| j                  C| j                  j                          |j                  j                  j                  d      dk(  ryt        |   |      S r   r   r   s     r/   r   zAsyncAnthropic._should_retry	  r   r1   c                h   K   t         |           d {    t        | j                         y 7 wr   r   r   s    r/   r3   zAsyncAnthropic.close  s+     gmo 	4++, 	s   202r   c                  |
|t        d      ||t        d      | j                  }|
i ||
}n||}| j                  }|i ||}n||}|xs | j                  }|$t	        |t
              r|t        d      d|i|}nu|"t	        |t
              st        d      d|i|}nQt	        |t
              r| j                  n|}|1t        |       r&d|i|}t	        |t
              rd| j                  i|} | j                  d	|xs | j                  |xs | j                  |xs | j                  t	        |t
              r| j                  n||t        |	      r|	n| j                   ||d|S r   r   r   s                     r/   r   zAsyncAnthropic.copy!  r   r1   c               *   |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j
                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   dk(  rt        j                  |||      S |j                   d	k(  rt        j                  |||      S |j                   d
k(  rt        j                  |||      S |j                   dk\  rt        j                  |||      S t        |||      S r   r   r   s       r/   r   z!AsyncAnthropic._make_status_errorl  r   r1   )r>   rY   r?   rY   r5   rZ   r`   r   ra   rY   r:   r   rb   r   rc   r   rd   r   re   r   rf   httpx.AsyncClient | Nonerg   r   r\   r   r  r  )r  rS   )r  rU   )r  rO   )r  rQ   )r  r"  )r  r$  r  r  r  r  r  r  r
  )r>   rY   r?   rY   r5   r  r`   r   ra   rY   r:   r   rb   r   rf   r0  rc   r  rd   r   r   r   re   r   r   r   r   r  r  r   r  r  r  s   @r/   r-   r-     sp   ++##(( **L$$I
 #!%26+/"+/5>.4859 15 -25>5K/ K/ 	K/
 0K/ )K/ K/ )K/ 3K/ K/ 2K/ 3K/  .!K/2 &*3K/4 35K/6 
7K/Z & &
 # #
 ! !
  
 3 3 8 8 1  1 ;  ; & & 
9 
9 
  
 
 
( !  ! / / - - #!%=F+/"+/5>04&/488<599=+-!E
 E
 	E

 ;E
 )E
 E
 )E
 3E
 .E
 $E
 2E
 6E
 3E
 7E
  )!E
" 
#E
R L$E$E 	$E
 !$E 
$E $Er1   r-   c                  h    e Zd ZU ded<   d	dZed
d       Zedd       Zedd       Zedd       Z	y)r   r,   r   c                    || _         y r   r   r   r.   s     r/   r   z!AnthropicWithRawResponse.__init__  	    r1   c                F    ddl m}  || j                  j                        S )Nr	   )CompletionsWithRawResponse)r   r7  r   rM   )r   r7  s     r/   rM   z$AnthropicWithRawResponse.completions  s    E)$,,*B*BCCr1   c                F    ddl m}  || j                  j                        S )Nr	   )MessagesWithRawResponse)r   r9  r   rL   )r   r9  s     r/   rL   z!AnthropicWithRawResponse.messages  s    ?&t||'<'<==r1   c                F    ddl m}  || j                  j                        S )Nr	   )ModelsWithRawResponse)r   r;  r   rK   )r   r;  s     r/   rK   zAnthropicWithRawResponse.models  s    ;$T\\%8%899r1   c                F    ddl m}  || j                  j                        S )Nr	   )BetaWithRawResponse)r   r=  r   rJ   )r   r=  s     r/   rJ   zAnthropicWithRawResponse.beta  s    7"4<<#4#455r1   Nr.   r,   r  r  )r  z&completions.CompletionsWithRawResponse)r  z messages.MessagesWithRawResponse)r  zmodels.ModelsWithRawResponse)r  zbeta.BetaWithRawResponse
r  r  r  r  r   r   rM   rL   rK   rJ   r   r1   r/   r   r     s_     D D
 > >
 : :
 6 6r1   r   c                  h    e Zd ZU ded<   d	dZed
d       Zedd       Zedd       Zedd       Z	y)r"  r-   r   c                    || _         y r   r3  r4  s     r/   r   z&AsyncAnthropicWithRawResponse.__init__  r5  r1   c                F    ddl m}  || j                  j                        S )Nr	   )AsyncCompletionsWithRawResponse)r   rC  r   rM   )r   rC  s     r/   rM   z)AsyncAnthropicWithRawResponse.completions  s    J.t||/G/GHHr1   c                F    ddl m}  || j                  j                        S )Nr	   )AsyncMessagesWithRawResponse)r   rE  r   rL   )r   rE  s     r/   rL   z&AsyncAnthropicWithRawResponse.messages  s    D+DLL,A,ABBr1   c                F    ddl m}  || j                  j                        S )Nr	   )AsyncModelsWithRawResponse)r   rG  r   rK   )r   rG  s     r/   rK   z$AsyncAnthropicWithRawResponse.models  s    @)$,,*=*=>>r1   c                F    ddl m}  || j                  j                        S )Nr	   )AsyncBetaWithRawResponse)r   rI  r   rJ   )r   rI  s     r/   rJ   z"AsyncAnthropicWithRawResponse.beta  s    <'(9(9::r1   Nr.   r-   r  r  )r  z+completions.AsyncCompletionsWithRawResponse)r  z%messages.AsyncMessagesWithRawResponse)r  z!models.AsyncModelsWithRawResponse)r  zbeta.AsyncBetaWithRawResponser?  r   r1   r/   r"  r"    sa     I I
 C C
 ? ?
 ; ;r1   r"  c                  h    e Zd ZU ded<   d	dZed
d       Zedd       Zedd       Zedd       Z	y)r   r,   r   c                    || _         y r   r3  r4  s     r/   r   z&AnthropicWithStreamedResponse.__init__  r5  r1   c                F    ddl m}  || j                  j                        S )Nr	   ) CompletionsWithStreamingResponse)r   rN  r   rM   )r   rN  s     r/   rM   z)AnthropicWithStreamedResponse.completions  s    K/0H0HIIr1   c                F    ddl m}  || j                  j                        S )Nr	   )MessagesWithStreamingResponse)r   rP  r   rL   )r   rP  s     r/   rL   z&AnthropicWithStreamedResponse.messages  s    E,T\\-B-BCCr1   c                F    ddl m}  || j                  j                        S )Nr	   )ModelsWithStreamingResponse)r   rR  r   rK   )r   rR  s     r/   rK   z$AnthropicWithStreamedResponse.models  s    A*4<<+>+>??r1   c                F    ddl m}  || j                  j                        S )Nr	   )BetaWithStreamingResponse)r   rT  r   rJ   )r   rT  s     r/   rJ   z"AnthropicWithStreamedResponse.beta  s    =():):;;r1   Nr>  )r  z,completions.CompletionsWithStreamingResponse)r  z&messages.MessagesWithStreamingResponse)r  z"models.ModelsWithStreamingResponse)r  zbeta.BetaWithStreamingResponser?  r   r1   r/   r   r     sc     J J
 D D
 @ @
 < <r1   r   c                  h    e Zd ZU ded<   d	dZed
d       Zedd       Zedd       Zedd       Z	y)r$  r-   r   c                    || _         y r   r3  r4  s     r/   r   z+AsyncAnthropicWithStreamedResponse.__init__  r5  r1   c                F    ddl m}  || j                  j                        S )Nr	   )%AsyncCompletionsWithStreamingResponse)r   rX  r   rM   )r   rX  s     r/   rM   z.AsyncAnthropicWithStreamedResponse.completions  s    P4T\\5M5MNNr1   c                F    ddl m}  || j                  j                        S )Nr	   )"AsyncMessagesWithStreamingResponse)r   rZ  r   rL   )r   rZ  s     r/   rL   z+AsyncAnthropicWithStreamedResponse.messages  s    J1$,,2G2GHHr1   c                F    ddl m}  || j                  j                        S )Nr	   ) AsyncModelsWithStreamingResponse)r   r\  r   rK   )r   r\  s     r/   rK   z)AsyncAnthropicWithStreamedResponse.models  s    F/0C0CDDr1   c                F    ddl m}  || j                  j                        S )Nr	   )AsyncBetaWithStreamingResponse)r   r^  r   rJ   )r   r^  s     r/   rJ   z'AsyncAnthropicWithStreamedResponse.beta	  s    B-dll.?.?@@r1   NrJ  )r  z1completions.AsyncCompletionsWithStreamingResponse)r  z+messages.AsyncMessagesWithStreamingResponse)r  z'models.AsyncModelsWithStreamingResponse)r  z#beta.AsyncBetaWithStreamingResponser?  r   r1   r/   r$  r$    se     O O
 I I
 E E
 A Ar1   r$  )r.   r  r  r   )r5   r  r  r  )r5   rZ   r:   r|   r  r  )r>   rY   r?   rY   r5   r  r  r  )r>   rY   r?   rY   r  r  )T
__future__r   rE   typingr   r   r   typing_extensionsr   r   httpx r
   r   _qsr   _typesr   r   r   r   r   r   r   r   _utilsr   r   r   _compatr   _versionr   
_streamingr   r   r   _base_clientr   r   r    lib.credentialsr!   r"   r#   r$   r%   r&   lib.credentials._authr'   r(   lib.credentials._constantsr)   r0   r6   r<   rA   rI   	resourcesrJ   rK   rL   rM   r   rN   rO   resources.beta.betarP   rQ   r   rR   rS   resources.messages.messagesrT   rU   __all__r,   r-   r   r"  r   r$  rV   rW   r   r1   r/   <module>rr     s    # 	 . . ,  % 	 	 	 
 % ! D '   K7	?G  >>54DD	GE GETCE^ CEL6 6>; ;>< <>A A> 
r1   