dhSSKJr SSKrSSKrSSKJrJrJrJr SSK r SSK r SSK J r SSK Jr SSKJr SSKJr SSjr\ "S S S S 9"S S\\55rg)) annotationsN)AnyDictListOptional) deprecated) Embeddings)pre_init) BaseModelc[R"SXUS9nURS:Xag[SUR35e![RR an[SU35eSnAff=f)a^ Check if an endpoint is live by sending a GET request to the specified URL. Args: url (str): The URL of the endpoint to check. Returns: bool: True if the endpoint is live (status code 200), False otherwise. Raises: Exception: If the endpoint returns a non-successful status code or if there is an error querying the endpoint. POSTheadersdataTz0Endpoint returned a non-successful status code: zError querying the endpoint: N)requestsrequest status_code Exception exceptionsRequestException)urlrpayloadresponsees [/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/embeddings/nemo.pyis_endpoint_livers=##FCwO   3 &B''(*     / /=7s;<<=s&AAA2A--A2z0.0.37z1.0.0zDirectly instantiating a NeMoEmbeddings from langchain-community is deprecated. Please use langchain-nvidia-ai-endpoints NVIDIAEmbeddings interface.)sinceremovalmessagec\rSrSr%SrSrS\S'SrS\S'S rS\S '\ SS j5r SS jr SS jr SSjr SSjrSSjrSSjrSrg)NeMoEmbeddings.zNeMo embedding models.int batch_sizezNV-Embed-QA-003strmodelz#http://localhost:8088/v1/embeddingsapi_endpoint_urlcnUSnUSnSS0n[R"SUSS.5n[X$U5 U$)zHValidate that the end point is alive using the values that are provided.r)r( Content-Typeapplication/jsonz Hello Worldqueryinputr( input_type)jsondumpsr)clsvaluesrr(rrs rvalidate_environment#NeMoEmbeddings.validate_environment>sR'(w"#56**&%   w/ ch# SS0nURURX RUS.US9IShvN nUR5 UR 5IShvN n[ R "U5nUSSSsSSS5IShvN $N^N8N !,IShvN (df  g=f7f) zqAsync call out to embedding endpoint. Args: text: The text to embed. Returns: Embeddings for the text. r+r,r.)r1rNrr embedding)postr)r(raise_for_statustextr1loads)selfsessionr<r0rranswers r_aembedding_funcNeMoEmbeddings._aembedding_funcSs"#56<<  ! !**JO     % % '#==?*FZZ'F&>!$[1   +     sV1B2BB2$BB$B B2 B B2BB2B/B!  B/+B2c[R"UURUS.5nSS0n[R"SUR XCS9n[R "UR5nUSSSnU$) ztCall out to Cohere's embedding endpoint. Args: text: The text to embed. Returns: Embeddings for the text. r.r+r,r rrrr9)r1r2r(rrr)r=r<)r>r<r0rrr response_jsonr9s r_embedding_funcNeMoEmbeddings._embedding_funcks|**(  "#56## D))7  8==1 !&)!,[9 r7cJUVs/sHo RUSS9PM sn$s snf)zEmbed a list of document texts. Args: texts: The list of texts to embed. Returns: List of embeddings, one for each text. passager0rE)r> documentsr<s rembed_documentsNeMoEmbeddings.embed_documentss,NWWYT$$Ti$@YWWWs c"URUSS9$)Nr-rIrJ)r>r<s r embed_queryNeMoEmbeddings.embed_querys##DW#==r7c# [R"5IShvN nURX!S5IShvN nUsSSS5IShvN $N1NN !,IShvN (df  g=f7f)zCall out to NeMo's embedding endpoint async for embedding query text. Args: text: The text to embed. Returns: Embedding for the text. NrH)aiohttp ClientSessionrA)r>r<r?r9s r aembed_queryNeMoEmbeddings.aembed_querysL((**g"33G9MMI+**M+***sSA.AA.AAA A.A A.AA.A+A  A+'A.c # /n[R"5IShvN n[S[U5UR5HinXX@R-nUHPnUVs/sHnUR X6S5PM nn[ R"U6IShvN nURU5 MR Mk SSS5IShvN U$Ns snfN6N!,IShvN (df  U$=f7f)zCall out to NeMo's embedding endpoint async for embedding search docs. Args: texts: The list of texts to embed. Returns: List of embeddings, one for each text. NrrH) rRrSrangelenr&rAasynciogatherextend) r>texts embeddingsr?batch text_batchr<tasks batch_resultss raembed_documentsNeMoEmbeddings.aembed_documentss ((**gq#e*doo>"5??+BC &D%/$.D--gYG$. +2..%*@$@M%%m4'?+*"#+  %A+**"sbC(CC(=C C :C C C 0 C(;C <C(C  C( C%C  C% C(N)r4rreturnr)r?rr<r'r0r're List[float])r<r'r0r'rerf)rK List[str]reList[List[float]])r<r'rerf)r\rgrerh)__name__ __module__ __qualname____firstlineno____doc__r&__annotations__r(r)r r5rArErLrOrTrb__static_attributes__rdr7rr"r".sw!J"E3"AcA (22"%2362 206 X> r7r")rr'rzOptional[dict]rrrebool) __future__rrYr1typingrrrrrRrlangchain_core._api.deprecationrlangchain_core.embeddingsr langchain_core.utilsr pydanticr rr"rdr7rrws[" ,,60)=>    GY GGr7