dh/SSKJr SSKrSSKrSSKJrJrJrJrJ r J r J r J r J r Jr SSKJr SSKJrJrJr SSKJrJrJrJr SSKJrJrJrJrJrJ r \RB"\"5r#SS jr$SS jr%SS jr&SS jr'SS jr("SS\\5r)g)) annotationsN) AnyCallableDictListLiteralOptionalSequenceSetTupleUnion) Embeddings)get_from_dict_or_envget_pydantic_field_namespre_init) BaseModel ConfigDictFieldmodel_validator) AsyncRetryingbefore_sleep_logretryretry_if_exception_typestop_after_attemptwait_exponentialLocalAIEmbeddingsc SSKnSnSn[S[UR5[ SX#S9[ UR R5[ UR R5-[ UR R5-[ UR R5-[ UR R5-[[[R5S9$)Nr T multiplierminmaxreraisestopwaitr before_sleep)openairr max_retriesrrerrorTimeoutAPIErrorAPIConnectionErrorRateLimitErrorServiceUnavailableErrorrloggerloggingWARNING) embeddingsr* min_seconds max_secondss ^/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/embeddings/localai.py_create_retry_decoratorr9%sKK   6 6 7  M #FLL$8$8 9%fll&;&;< =%fll&E&EF G&fll&A&AB C&fll&J&JK  L &fgoo>  c ^SSKnSnSn[S[UR5[ SX#S9[ UR R5[ UR R5-[ UR R5-[ UR R5-[ UR R5-[[[R5S9mS U4SjjnU$) NrrrTr r!r%c>^SUU4SjjnU$)Ncf># TShvN nT"U0UD6IShvN s $NN [S5e7f)Nzthis is unreachable)AssertionError)argskwargs_async_retryingfuncs r8 wrapped_f7_async_retry_decorator..wrap..wrapped_fQs<) 3a!426222 32* !67 7s(1%!% 1#1%1 1)r?rr@rreturnr)rCrDrBs` r8wrap$_async_retry_decorator..wrapPs 8 8 r:)rCrrFr)r*rrr+rrr,r-r.r/r0r1rr2r3r4)r5r*r6r7rHrBs @r8_async_retry_decoratorrJ;sKK#  6 6 7  M #FLL$8$8 9%fll&;&;< =%fll&E&EF G&fll&A&AB C&fll&J&JK  L &fgoo> N Kr:cx[SUS55(aSSKnURRS5eU$)Nc3B# UHn[US5S:Hv M g7f) embeddingr N)len).0ds r8 "_check_response..]s >-=3q~ ! #-=sdatarz'LocalAI API returned an empty embedding)anyr*r,r.)responser*s r8_check_responserV\s6 >Xf-= >>>ll##$MNN Or:c D^[T5nUSU4Sjj5nU"S0UD6$))Use tenacity to retry the embedding call.cR>TRR"S0UD6n[U5$NrG)clientcreaterVr@rUr5s r8_embed_with_retry+embed_with_retry.._embed_with_retryhs'$$++5f5x((r:r@rrFrrG)r9)r5r@retry_decoratorr^s` r8embed_with_retryrbds/-j9O))  &v &&r:c\^# [T5SU4Sjj5nU"S0UD6IShvN $N7f)rXcn># TRR"S0UD6IShvN n[U5$N7frZ)r[acreaterVr]s r8_async_embed_with_retry7async_embed_with_retry.._async_embed_with_retryss2#**22Build extra kwargs from additional params that were passed in.rzFound z supplied twice.z WARNING! z/ is not default parameter. zJ was transferred to model_kwargs. Please confirm that z is what you intended.z Parameters za should be specified explicitly. Instead they were passed in as part of `model_kwargs` parameter.) rgetlist ValueErrorwarningswarnpop intersectionkeys)clsvaluesall_required_field_namesr field_nameinvalid_model_kwargss r8 build_extraLocalAIEmbeddings.build_extras$2.v,J" 6*5E!FGG9 !*.L!))3 4JN %+JJz$:!' 8DDUZZ\R 234ST  "'~ r:c[USS5US'[USSSS9US'[USSSS9US'Sn[US S US9US '[US S SS9US 'S SKnURUS'U$![a [S5ef=f)z?Validate that api key and python package exists in environment.rsOPENAI_API_KEYroOPENAI_API_BASE)defaultrp OPENAI_PROXYrnOPENAI_API_VERSIONrtOPENAI_ORGANIZATIONrNr[zTCould not import openai python package. Please install it with `pip install openai`.)rr* Embedding ImportError)rrdefault_api_versionr*s r8validate_environment&LocalAIEmbeddings.validate_environments$8 $&6$  %9    %  ! "6    " ~!';  ' ( #$ )=  ! ! ) $%   %//F8    ?  s A%%A;c$URURURURURUR UR S.UREnUR(a"SSK nURURS.Ul U$)N)rlrzr{api_key organizationapi_base api_versionr)httphttps) rlrzr{rsrtrornrrpr*proxy)self openai_argsr*s r8_invocation_params$LocalAIEmbeddings._invocation_paramssZZ#33||** 44,,22        ))**FLr:cURRS5(aURSS5n[U4SU/0URD6SSS$))Call out to LocalAI's embedding endpoint.001  inputrSrrM)rlendswithreplacerbrrtextengines r8_embedding_func!LocalAIEmbeddings._embedding_funcss ::  u % %<<c*D  & %%    ! " "r:c# URRS5(aURSS5n[U4SU/0URD6IShvN SSS$N 7f) rrrrrNrSrrM)rlrrrhrrs r8_aembedding_func"LocalAIEmbeddings._aembedding_funcs ::  u % %<<c*D(f))      ! " " sAA!AA!c\UVs/sHo0RX0RS9PM sn$s snf)aCall out to LocalAI's embedding endpoint for embedding search docs. Args: texts: The list of texts to embed. chunk_size: The chunk size of embeddings. If None, will use the chunk size specified by the class. Returns: List of embeddings, one for each text. rrrm)rtextsrxrs r8embed_documents!LocalAIEmbeddings.embed_documents"s.PUUut$$T//$BuUUUs!)c# /nUH5nURX@RS9IShvN nURU5 M7 U$N7f)aCall out to LocalAI's embedding endpoint async for embedding search docs. Args: texts: The list of texts to embed. chunk_size: The chunk size of embeddings. If None, will use the chunk size specified by the class. Returns: List of embeddings, one for each text. rN)rrmappend)rrrxr5rrUs r8aembed_documents"LocalAIEmbeddings.aembed_documents2sL D!2242PPH   h 'Qs$AAAc8URXRS9nU$)zCall out to LocalAI's embedding endpoint for embedding query text. Args: text: The text to embed. Returns: Embedding for the text. rrrrrMs r8 embed_queryLocalAIEmbeddings.embed_queryEs!((oo(F r:cT# URXRS9IShvN nU$N7f)zCall out to LocalAI's embedding endpoint async for embedding query text. Args: text: The text to embed. Returns: Embedding for the text. rN)rrmrs r8 aembed_queryLocalAIEmbeddings.aembed_queryQs-//__/MM Ns (&()rrrFr)rrrFr)rFr)rrkrrkrF List[float])r)rz List[str]rxz Optional[int]rFzList[List[float]])rrkrFr)*__name__ __module__ __qualname____firstlineno____doc__r[__annotations__rlrmrnrorprrrsrtsetrurwrxr+rzr{r}rdictrr model_configr classmethodrrrpropertyrrrrrrr__static_attributes__rGr:r8rr{s(FC)E3)J(, ,%)O])"&L-& $#$8$(NM()--7:uO4L.>VH2FL(#$2((T( " " =>VV,9V V"=>,9 &  r:)r5rrFzCallable[[Any], Any])r5rrFr)rUrrFr)r5rr@rrFr)* __future__rr3rtypingrrrrrr r r r r langchain_core.embeddingsrlangchain_core.utilsrrrpydanticrrrrtenacityrrrrrr getLoggerrr2r9rJrVrbrhrrGr:r8rs{"   1 CB   8 $,B '3` :`r: