jGddlmZddlZddlZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZmZddlZddlmZmZmZmZddlmZdd lmZmZdd lmZdd lm Z dd l!m"Z"m#Z#dd l$m%Z%ddl&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m-Z0m.Z1e ge2fZ3e gdfZ4edeejjejlfZ7edee"ee#efZ8Gdde%Z9Gdde(e7e8fZ:Gdde-Z;Gdde0Z<Gdde*Z=Gdd e.Z>Gd!d"e1Z?Gd#d$e+Z@Gd%d&e:ejje"efeZAGd'd(e:ejle#efeZBy))) annotationsN)AnyUnionMappingTypeVarCallable Awaitablecastoverload)cached_property)Selfoverride) NOT_GIVENOmitTimeoutNotGiven)is_given) AnthropicAsyncAnthropic) model_copy)FinalRequestOptions)Stream AsyncStream)AnthropicError)DEFAULT_MAX_RETRIES BaseClient)Beta AsyncBeta)Messages AsyncMessageszstr | Awaitable[str] _HttpxClientT)bound_DefaultStreamTc eZdZdfd ZxZS)MutuallyExclusiveAuthErrorc$t|dy)NznThe `api_key` and `azure_ad_token_provider` arguments are mutually exclusive; Only one can be passed at a time)super__init__)self __class__s H/var/www/html/venv/lib/python3.12/site-packages/anthropic/lib/foundry.pyr)z#MutuallyExclusiveAuthError.__init__s  | returnNone)__name__ __module__ __qualname__r) __classcell__r+s@r,r&r&s   r-r&c eZdZy)BaseFoundryClientN)r1r2r3r-r,r7r7$sr-r7c(eZdZeeddZy)MessagesFoundrycyz?Batches endpoint is not supported for Anthropic Foundry client.Nr8r*s r,batcheszMessagesFoundry.batches(r-Nr.r1r2r3r rr>r8r-r,r:r:' r-r:c(eZdZeeddZy)BetaFoundryMessagescyr<r8r=s r,r>zBetaFoundryMessages.batches0r?r-Nr.r@r8r-r,rCrC/rAr-rCc(eZdZeeddZy) BetaFoundryc,t|jSzKReturn beta messages resource instance with excluded unsupported endpoints.)rC_clientr=s r,messageszBetaFoundry.messages8s#4<<00r-N)r/ BetaMessagesr1r2r3r rrJr8r-r,rFrF7s 11r-rFc(eZdZeeddZy)AsyncMessagesFoundrycyr<r8r=s r,r>zAsyncMessagesFoundry.batches@r?r-Nr.r@r8r-r,rNrN?rAr-rNc(eZdZeeddZy)AsyncBetaFoundryMessagescyr<r8r=s r,r>z AsyncBetaFoundryMessages.batchesHr?r-Nr.r@r8r-r,rQrQGrAr-rQc(eZdZeeddZy)AsyncBetaFoundryc,t|jSrH)rQrIr=s r,rJzAsyncBetaFoundry.messagesPs( 55r-N)r/AsyncBetaMessagesrLr8r-r,rTrTOs 66r-rTceZdZeddddeeddddd ddZedddeeddddd ddZdddddeeddddd dfdZeedd Z eedd Z eedd Z edddddededdddid dfd Z e Z ddZeddZxZS)AnthropicFoundryNF resourceapi_keyazure_ad_token_provider webhook_keytimeout max_retriesdefault_headers default_query http_client_strict_response_validationc yNr8 r*rZr[r\r]r^r_r`rarbrcs r,r)zAnthropicFoundry.__init__[r- r[r\r]r^r_r`rarbrcc yrer8 r*base_urlr[r\r]r^r_r`rarbrcs r,r)zAnthropicFoundry.__init__krgr- rZr[r\r]rkr^r_r`rarbrcc z||ntjjd}||ntjjd}||ntjjd}| | td|| t dd|d}n | t d t |||||||| | | ||_y) aConstruct a new synchronous Anthropic Foundry client instance. This automatically infers the following arguments from their corresponding environment variables if they are not provided: - `api_key` from `ANTHROPIC_FOUNDRY_API_KEY` - `resource` from `ANTHROPIC_FOUNDRY_RESOURCE` - `base_url` from `ANTHROPIC_FOUNDRY_BASE_URL` Args: resource: Your Foundry resource name, e.g. `example-resource` for `https://example-resource.services.ai.azure.com/anthropic/` azure_ad_token_provider: A function that returns an Azure Active Directory token, will be invoked on every request. NANTHROPIC_FOUNDRY_API_KEYANTHROPIC_FOUNDRY_RESOURCEANTHROPIC_FOUNDRY_BASE_URLMissing credentials. Please pass one of `api_key`, `azure_ad_token_provider`, or the `ANTHROPIC_FOUNDRY_API_KEY` environment variable.tMust provide one of the `base_url` or `resource` arguments, or the `ANTHROPIC_FOUNDRY_RESOURCE` environment variablehttps://!.services.ai.azure.com/anthropic/,base_url and resource are mutually exclusive r[r]rkr^r_r`rarbrcosenvirongetr ValueErrorr(r)_azure_ad_token_provider r*rZr[r\r]rkr^r_r`rarbrcr+s r,r)zAnthropicFoundry.__init__{4%0'bjjnnE`6a'38Hd9e'38Hd9e ?6> Y    K"(+LMH  !KL L ##+'#(C  )@%r-cy)z>Models endpoint is not supported for Anthropic Foundry client.Nr8r=s r,modelszAnthropicFoundry.modelsr?r-ct|SzFReturn messages resource instance with excluded unsupported endpoints.client)r:r=s r,rJzAnthropicFoundry.messagessd++r-ct|S)BReturn beta resource instance with excluded unsupported endpoints.)rFr=s r,betazAnthropicFoundry.betas4  r- r[r\ auth_tokenr]rkr^rbr_r`set_default_headersraset_default_query _extra_kwargsc ^t||||||||| | | | d|xs |ji|  Sz~ Create a new client instance re-using the same options given to the current client with optional overriding. r\) r[rr]rkr^rbr_r`rrarrr(copyr|r*r[r\rr]rkr^rbr_r`rrarrr+s r,rzAnthropicFoundry.copyZ*w|!###+ 3'/)+B+cdFcFc  r-cr|j}|)|}|rt|tstd||SyNzOExpected `azure_ad_token_provider` argument to return a string but it returned )r| isinstancestrr{r*providertokens r,_get_azure_ad_tokenz$AnthropicFoundry._get_azure_ad_tokensI00  JE 5# 6 efkelmLr-cXt|jri|jni}t|}||_|j}||j dd||d<|S|j 0|j d|j J|j |d<|St dN AuthorizationzBearer zapi-keyzUnable to handle authrheadersrrrzr[r{r*optionsrazure_ad_tokens r,_prepare_optionsz!AnthropicFoundry._prepare_optionss@H@Y).4859+/,1    "=   3  2 3 ) &*     #?C"&5>.4859+/,1    "=   3  2 3 ) &*    $ $"?C"&#5>.4859+/,17@7@ 7@ "= 7@  7@7@37@7@27@37@)7@&*7@ 7@r  ,, !!#?C!%"&+/5>+/&/488<599=+-$ $ "= $  $  $ )$ 3$ )$ $$ 2$ 6$ 3$ 7$ )$ !$ $ LL r-rXceZdZeddddeeddddd ddZedddeeddddd ddZdddddeeddddd dfdZeedd Z eedd Z eedd Z edddddededdddid dfd Z e Z ddZeddZxZS)AsyncAnthropicFoundryNFrYc yrer8rfs r,r)zAsyncAnthropicFoundry.__init__rgr-rhc yrer8rjs r,r)zAsyncAnthropicFoundry.__init__"rgr-rlc z||ntjjd}||ntjjd}||ntjjd}| | td|| t dd|d}n | t d t |||||||| | | ||_y) aConstruct a new asynchronous Anthropic Foundry client instance. This automatically infers the following arguments from their corresponding environment variables if they are not provided: - `api_key` from `ANTHROPIC_FOUNDRY_API_KEY` - `resource` from `ANTHROPIC_FOUNDRY_RESOURCE` - `base_url` from `ANTHROPIC_FOUNDRY_BASE_URL` Args: resource: Your Foundry resource name, e.g. `example-resource` for `https://example-resource.services.ai.azure.com/anthropic/` azure_ad_token_provider: A function that returns an Azure Active Directory token, will be invoked on every request. Nrnrorprqrrrsrtrurvrwr}s r,r)zAsyncAnthropicFoundry.__init__2r~r-cy)zwr)r|inspect isawaitablerr rrr{rs r,rz)AsyncAnthropicFoundry._get_azure_ad_tokenss00  JE""5)#  4U+;S A efkelmu: $s0A3A1?A3ctKt|jri|jni}t|}||_|jd{}||j dd||d<|S|j 0|j J|j d|j |d<|St d7hwrrrs r,rz&AsyncAnthropicFoundry._prepare_optionss@H@Y).485904,1    "B   3  2 3 . &*     #DH"&5>.485904,1    "B   3  2 3 . &*    $ $"DH"&#5>.485904,17@7@ 7@ "B 7@  7@7@37@7@27@37@.7@&*7@ 7@r  11 --#DH!%"&+/5>04&/488<599=+-$ $ "B $  $  $ )$ 3$ .$ $$ 2$ 6$ 3$ 7$ )$ !$ $ LL r-r)C __future__rrxrtypingrrrrrr r r functoolsr typing_extensionsr rhttpx_typesrrrr_utilsrrIrr_compatr_modelsr _streamingrr _exceptionsr _base_clientrrresources.betarrresources.messagesr r!resources.beta.messagesrKrVrAzureADTokenProviderAsyncAzureADTokenProviderClient AsyncClientr"r$r&r7r:rCrFrNrQrTrXrr8r-r,rsZ" TTT%, 77/ ),(:,8bC($R)?%?@uU\\5CTCT5T/UV +5kRUFV9V3WX  I =/#ABHh,1$1=06y6t(vc{)BCYtnv-e.?.?SAQ.QRTbvr-