o 6Wj@s*ddlmZddlZddlmZmZmZmZddlm Z m Z ddl Z ddl m Z mZddlmZddlmZmZmZmZmZmZmZmZdd lmZmZmZdd lmZdd l m!Z!dd l"m#Z#m$Z$dd lm%Z%ddl&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6ddl7m8Z8d;ddZ9dd%d&Zm?Z?m@Z@mAZAmBZBdd*lCmDZDmEZEdd+lFmGZGmHZHdd,lImJZJmKZKdd-lLmMZMmNZNgd.ZOGd/d0d0e*ZPGd1d2d2e+ZQGd3d4d4ZRGd5d6d6ZSGd7d8d8ZTGd9d:d:ZUePZVeQZWdS)@) annotationsN) TYPE_CHECKINGAnyMappingSequence)Selfoverride) _constants _exceptions Querystring)OmitHeadersTimeoutNotGiven Transport ProxiesTypesRequestOptions not_given)is_given is_mapping_tget_async_library)cached_property) __version__)Stream AsyncStream)APIStatusError)MiddlewareInput)DEFAULT_MAX_RETRIES SyncAPIClientAsyncAPIClient merge_headers) TokenCacheInMemoryConfigAccessTokenAuthCredentialsFileAccessTokenProviderdefault_credentials)&warn_env_static_shadows_auto_discovery(warn_explicit_static_shadows_credentials)"_has_auto_discoverable_credentialsclientobjectreturnboolcCst|ttfvS)a0True 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 AnthropicAsyncAnthropic)r,r3`/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anthropic/_client.py_is_base_client8sr5 credentialsNonecCs"t|dd}|dur|dSdS)zPRelease any resources owned by a credential provider, if it exposes ``close()``.closeN)getattr)r6r8r3r3r4_close_credentialsBs  r:AccessTokenProvider | Nonebase_urlstrcCs$t|dd}t|r||dSdS)uIf 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)r9callable)r6r<bindr3r3r4_bind_credentials_base_urlIs  rAapi_key str | None auth_tokencCs4|durdS|durtd|durtddSdS)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.NrBrD)r*rBrDr6r3r3r4_warn_explicit_shadowWs rFcCsNtsdS|durtjdrtd|dur#tjdr%tddSdSdS)avWarn 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.NANTHROPIC_API_KEYANTHROPIC_AUTH_TOKEN)r+osenvirongetr)rBrDr3r3r4_warn_env_shadowcs rM)betamodelsmessages completions)Models AsyncModels)Beta AsyncBeta) CompletionsAsyncCompletions)Messages AsyncMessages)rrrrr1r2Client AsyncClientceZdZUded<ded<ded<ded<ded<d ed <ejZejZd d d d d d d eed d d d d ed dhfd$d%Z e did'd(Z e djd*d+Z e dkd-d.Z e dld0d1Ze dmd3d4Ze dnd6d7Zeedod9d:Zeedpdd?Zedpd@dAZeedqfdCdD ZedrdHdIZeedsdKdLZedtfdOdP ZedufdQdR Zd d ed d d d ed ed d d d eidSdvd\d]ZeZdwd_d`ZedxdfdgZZ S)yr1rCrBrD webhook_keyr;r6TokenCache | None _token_cacheAccessTokenAuth | None _custom_authNFrBrDr6configprofiler]r<timeout max_retriesdefault_headers default_query http_client middleware_strict_response_validationr_rcMapping[str, Any] | Nonerdr<str | httpx.URL | Nonere!float | Timeout | None | NotGivenrfintrgMapping[str, str] | NonerhMapping[str, object] | Nonerihttpx.Client | Nonerj Sequence[MiddlewareInput] | Nonerkr/TokenCache | None | NotGivenr.r7c |dup|dup|dup|dup|du}|s"tjd}tjd}||_||_|dur2tjd}||_|dur?tjd}|du}|durId}tjd}|duri}|dD]}|d }|d krw||d d||d|<qZi|t | r| ni} i}|dur|dus|durt d t t |}|}| }|s|jr|j}n|dur|durt d t|d }|}| }|s|jr|j}|dur|dur|durt|rt|rt|ndd}|dur|j}|j }|s|jr|j}t|t|||_t|||dt||dt|ts||_n |dur!t|nd|_|jdur/t|jnd|_|r>i|| p/configs/.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 ``/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. NrGrHANTHROPIC_WEBHOOK_SIGNING_KEYANTHROPIC_BASE_URLhttps://api.anthropic.comANTHROPIC_CUSTOM_HEADERS :rr =Pass at most one of `credentials=`, `config=`, or `profile=`.rdr<rErL versionr<rfrericustom_headers custom_queryrjrk)$rIrJrKrBrDr]splitfindstripr TypeErrorr$dict extra_headersresolved_base_urlr&r5r(r=providerr<rAr6rFrM isinstancerr_r#r%rasuper__init__rr_default_stream_clsselfrBrDr6rcrdr]r<rerfrgrhrirjrkr_has_explicit_credentialbase_url_is_explicitcustom_headers_envparsedlinecoloncredential_headers in_memory creds_fileresult __class__r3r4r<      $         zAnthropic.__init__rVcCddlm}||S)Nr )rV)resources.completionsrV)rrVr3r3r4rQ' zAnthropic.completionsrXcCr)Nr )rX)resources.messagesrX)rrXr3r3r4rP-rzAnthropic.messagesrRcCr)Nr )rR)resources.modelsrR)rrRr3r3r4rO3rzAnthropic.modelsrTcCr)Nr )rT)resources.betarT)rrTr3r3r4rN9rzAnthropic.betaAnthropicWithRawResponsecCt|SN)rrr3r3r4with_raw_response?zAnthropic.with_raw_responseAnthropicWithStreamedResponsecCrr)rrr3r3r4with_streaming_responseCrz!Anthropic.with_streaming_responser cC tddSNbrackets) array_formatr rr3r3r4qsG z Anthropic.qsdict[str, str]cCi|j|jSr _api_key_auth _bearer_authrr3r3r4 auth_headersLzAnthropic.auth_headerscC|j}|dur iSd|iSN X-Api-KeyrBrrBr3r3r4rQzAnthropic._api_key_authcC |j}|dur iSdd|iSN AuthorizationzBearer rDrrDr3r3r4rXzAnthropic._bearer_authdict[str, str | Omit]csitjddd|jS)Nfalse 2023-06-01zX-Stainless-Asynczanthropic-version)rrg_custom_headersrrr3r4rgeszAnthropic.default_headersheadersrrcC~|jdur|ds|dsdS|ds|drdS|ds*t|dtr,dS|ds9t|dtr;dStdNrrz"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_rKrrrrrrr3r3r4_validate_headersos zAnthropic._validate_headershttpx.Auth | NonecC|jSrrarr3r3r4 custom_authzAnthropic.custom_authresponsehttpx.Responsec@|jdkr|jdur|j|jjddkrdSt|SNzx-stainless-retry-count0T status_coder_ invalidaterequestrrKr _should_retryrrrr3r4r   zAnthropic._should_retrycstt|jdSrrr8r:r6rrr3r4r8s zAnthropic.closerBrDr6rcrdr]r<rerirfrgset_default_headersrhset_default_queryrj _extra_kwargs%AccessTokenProvider | None | NotGivenint | NotGivenrr+Sequence[MiddlewareInput] | None | NotGivenrMapping[str, Any]rcC| dur | dur td| dur|durtd|j}| dur%t|| }n| dur+| }|j}| dur9i|| }n|dur?|}| pC|j} |dur\t|trQ|durUtdd|i|}n8|durpt|tsitdd|i|}n$t|trx|jn|}|durt |rd|i|}t|trd|j i|}|j d |p|j |p|j |p|j|p|jt|tr|jn|| t| r| n|j||t|tr|jn|d |S z~ Create a new client instance re-using the same options given to the current client with optional overriding. NzPThe `default_headers` and `set_default_headers` arguments are mutually exclusivezLThe `default_query` and `set_default_query` arguments are mutually exclusiver|rcrdr6r_) rBrDr]r<rerirfrgrhrjr3 ValueErrorrr" _custom_query_clientrrrr6r5r_rrBrDr]r<rerrf _middlewarerrBrDr6rcrdr]r<rerirfrgrrhrrjrrparamsresolved_credentialsr3r3r4copyT      zAnthropic.copyrcG|jg|j|dSzA new client with the given middleware appended after this client's middleware. Convenience for applying extra middleware to a single request: ```py client.with_middleware(my_middleware).messages.create(...) ``` )rjrrrrjr3r3r4with_middleware zAnthropic.with_middlewareerr_msgr=bodyr-rcC|jdkr tj|||dS|jdkrtj|||dS|jdkr'tj|||dS|jdkr4tj|||dS|jdkrAtj|||dS|jdkrNtj|||dS|jdkr[tj|||dS|jd krhtj |||dS|jd krutj |||dS|jd krtj |||dSt |||dS Ni)rrriiiiiiii rr BadRequestErrorAuthenticationErrorPermissionDeniedError NotFoundError ConflictErrorRequestTooLargeErrorUnprocessableEntityErrorRateLimitErrorOverloadedErrorInternalServerErrorrrrrrr3r3r4_make_status_error*          zAnthropic._make_status_error) rBrCrDrCr6r;rcrlrdrCr]rCr<rmrernrfrorgrprhrqrirrrjrsrkr/r_rtr.r7)r.rV)r.rX)r.rR)r.rT)r.r)r.rr.r r.rr.rrrrrr.r7r.rrrr.r/r.r7)"rBrCrDrCr6rrcrlrdrCr]rCr<rmrernrirrrfrrgrprrprhrqrrqrjrrrr.rrjrr.rrr=rr-rrr.r!__name__ __module__ __qualname____annotations__r HUMAN_PROMPT AI_PROMPTrrrrrQrPrOrNrrpropertyrrrrrrgrrrr8r with_optionsrr  __classcell__r3r3rr4r1s             M  r1cr\)yr2rCrBrDr]r;r6r^r_r`raNFrbrcrlrdr<rmrernrfrorgrprhrqrihttpx.AsyncClient | Nonerjrsrkr/rtr.r7c ru)ucConstruct 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 ``/configs/.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 ``/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. NrGrHrvrwrxryrzr{rr r|r}r~rErLr)$rIrJrKrBrDr]rrrrrr$rrrr&r5r(r=rr<rAr6rFrMrrr_r#r%rarrrrrrrr3r4r4rzAsyncAnthropic.__init__rWcCr)Nr )rW)rrW)rrWr3r3r4rQrzAsyncAnthropic.completionsrYcCr)Nr )rY)rrY)rrYr3r3r4rPrzAsyncAnthropic.messagesrScCr)Nr )rS)rrS)rrSr3r3r4rOrzAsyncAnthropic.modelsrUcCr)Nr )rU)rrU)rrUr3r3r4rNrzAsyncAnthropic.betaAsyncAnthropicWithRawResponsecCrr)r#rr3r3r4rrz AsyncAnthropic.with_raw_response"AsyncAnthropicWithStreamedResponsecCrr)r$rr3r3r4rrz&AsyncAnthropic.with_streaming_responser cCrrr rr3r3r4rrzAsyncAnthropic.qsrcCrrrrr3r3r4rrzAsyncAnthropic.auth_headerscCrrrrr3r3r4rrzAsyncAnthropic._api_key_authcCrrrrr3r3r4rrzAsyncAnthropic._bearer_authrcs$itjdtdd|jS)Nzasync:rr)rrgrrrrr3r4rgs zAsyncAnthropic.default_headersrrrcCrrrrr3r3r4rsz AsyncAnthropic._validate_headersrcCrrrrr3r3r4r%rzAsyncAnthropic.custom_authrrcrrrrrr3r4r*rzAsyncAnthropic._should_retrycs tIdHt|jdSrrrrr3r4r89szAsyncAnthropic.closerrrrrrrrrcCrrrrr3r3r4rBrzAsyncAnthropic.copyrcGrrrrr3r3r4rrzAsyncAnthropic.with_middlewarerr=rr-rcCrrrr r3r3r4r rz!AsyncAnthropic._make_status_error) rBrCrDrCr6r;rcrlrdrCr]rCr<rmrernrfrorgrprhrqrir"rjrsrkr/r_rtr.r7)r.rW)r.rY)r.rS)r.rU)r.r#)r.r$rrrrrrr)"rBrCrDrCr6rrcrlrdrCr]rCr<rmrernrir"rfrrgrprrprhrqrrqrjrrrr.rrrrr3r3rr4r2's             M  r2c@XeZdZUded<dddZedd d Zedd d ZedddZedddZ dS)rr1rr,r.r7cC ||_dSrrrr,r3r3r4r z!AnthropicWithRawResponse.__init__&completions.CompletionsWithRawResponsecCddlm}||jjS)Nr )CompletionsWithRawResponse)rr,rrQ)rr,r3r3r4rQ  z$AnthropicWithRawResponse.completions messages.MessagesWithRawResponsecCr+)Nr )MessagesWithRawResponse)rr/rrP)rr/r3r3r4rPr-z!AnthropicWithRawResponse.messagesmodels.ModelsWithRawResponsecCr+)Nr )ModelsWithRawResponse)rr1rrO)rr1r3r3r4rOr-zAnthropicWithRawResponse.modelsbeta.BetaWithRawResponsecCr+)Nr )BetaWithRawResponse)rr3rrN)rr3r3r3r4rNr-zAnthropicWithRawResponse.betaNr,r1r.r7)r.r*)r.r.)r.r0)r.r2 rrrrrrrQrPrOrNr3r3r3r4r     rc@r%)r#r2rr,r.r7cCr&rr'r(r3r3r4rr)z&AsyncAnthropicWithRawResponse.__init__+completions.AsyncCompletionsWithRawResponsecCr+)Nr )AsyncCompletionsWithRawResponse)rr8rrQ)rr8r3r3r4rQr-z)AsyncAnthropicWithRawResponse.completions%messages.AsyncMessagesWithRawResponsecCr+)Nr )AsyncMessagesWithRawResponse)rr:rrP)rr:r3r3r4rPr-z&AsyncAnthropicWithRawResponse.messages!models.AsyncModelsWithRawResponsecCr+)Nr )AsyncModelsWithRawResponse)rr<rrO)rr<r3r3r4rOr-z$AsyncAnthropicWithRawResponse.modelsbeta.AsyncBetaWithRawResponsecCr+)Nr )AsyncBetaWithRawResponse)rr>rrN)rr>r3r3r4rNr-z"AsyncAnthropicWithRawResponse.betaNr,r2r.r7)r.r7)r.r9)r.r;)r.r=r5r3r3r3r4r#r6r#c@r%)rr1rr,r.r7cCr&rr'r(r3r3r4rr)z&AnthropicWithStreamedResponse.__init__,completions.CompletionsWithStreamingResponsecCr+)Nr ) CompletionsWithStreamingResponse)rrArrQ)rrAr3r3r4rQr-z)AnthropicWithStreamedResponse.completions&messages.MessagesWithStreamingResponsecCr+)Nr )MessagesWithStreamingResponse)rrCrrP)rrCr3r3r4rPr-z&AnthropicWithStreamedResponse.messages"models.ModelsWithStreamingResponsecCr+)Nr )ModelsWithStreamingResponse)rrErrO)rrEr3r3r4rOr-z$AnthropicWithStreamedResponse.modelsbeta.BetaWithStreamingResponsecCr+)Nr )BetaWithStreamingResponse)rrGrrN)rrGr3r3r4rNr-z"AnthropicWithStreamedResponse.betaNr4)r.r@)r.rB)r.rD)r.rFr5r3r3r3r4rr6rc@r%)r$r2rr,r.r7cCr&rr'r(r3r3r4r$r)z+AsyncAnthropicWithStreamedResponse.__init__1completions.AsyncCompletionsWithStreamingResponsecCr+)Nr )%AsyncCompletionsWithStreamingResponse)rrIrrQ)rrIr3r3r4rQ'r-z.AsyncAnthropicWithStreamedResponse.completions+messages.AsyncMessagesWithStreamingResponsecCr+)Nr )"AsyncMessagesWithStreamingResponse)rrKrrP)rrKr3r3r4rP-r-z+AsyncAnthropicWithStreamedResponse.messages'models.AsyncModelsWithStreamingResponsecCr+)Nr ) AsyncModelsWithStreamingResponse)rrMrrO)rrMr3r3r4rO3r-z)AsyncAnthropicWithStreamedResponse.models#beta.AsyncBetaWithStreamingResponsecCr+)Nr )AsyncBetaWithStreamingResponse)rrOrrN)rrOr3r3r4rN9r-z'AsyncAnthropicWithStreamedResponse.betaNr?)r.rH)r.rJ)r.rL)r.rNr5r3r3r3r4r$!r6r$)r,r-r.r/)r6r-r.r7)r6r;r<r=r.r7)rBrCrDrCr6r-r.r7)rBrCrDrCr.r7)X __future__rrItypingrrrrtyping_extensionsrrhttpxr r _qsr _typesrrrrrrrr_utilsrrr_compatr_versionr _streamingrrrrr _base_clientrr r!r"lib.credentialsr#r$r%r&r'r(lib.credentials._authr)r*lib.credentials._constantsr+r5r:rArFrM resourcesrNrOrPrQrrRrSresources.beta.betarTrUrrVrWresources.messages.messagesrXrY__all__r1r2rr#rr$rZr[r3r3r3r4sX  (           $