dhOlSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r J r J r J r J r SSKrSSKJr SSKJr SSKJr SSKJr SS KJr SS KJr SS KJrJr SS KJr SS KJ r J!r!J"r"J#r#J$r$J%r%J&r& \RN"\(5r)Sr*Sr+Sr,"SS\-\5r.S\ \#\&44Sjr/S\-4Sjr0"SS\5r1g)N)Enum) HTTPStatus)AnyDictListOptionalTuple) ClientTimeout)Document)get_runtime_environment)get_from_dict_or_env)VectorStoreRetriever) BaseModel)Responserequest)RequestException)App AuthContextContext FrameworkPromptQaRuntimez0.1.1zhttp://localhost:8000zhttps://api.daxa.aic$\rSrSrSrSrSrSrSrg)Routes%z2Routes available for the Pebblo API as enumerator.z/v1/app/discoverz /v1/promptz/v1/prompt/governanceN) __name__ __module__ __qualname____firstlineno____doc__retrieval_app_discoverpromptprompt_governance__static_attributes__rm/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/chains/pebblo_retrieval/utilities.pyrr%s</ F/r'rreturnc [5n[SURSS5S9n[R"5n[ UR [RSURSS5URUR[5URSS5URS S5S 9nS UR;aS Ul S Ul [RSU35 [RSU35 X4$)zFetch the current Framework and Runtime details. Returns: Tuple[Framework, Runtime]: Framework and Runtime for the current app instance. langchainlibrary_versionN)nameversionPWDplatformunknownruntimeruntime_version)hostpathr0os os_versioniplanguagelanguage_versionDarwindesktopzMac OSXz framework zruntime )r rgetr0unamernoder6environsystemr.get_iptyper2loggerdebug) runtime_env frameworkr>r2s r( get_runtimerH-s *+K +//2CT"JI NN E ZZ ZZ Y7 <<== 8I6$):IF G7::  # LL:i[)* LL8G9%&  r'cSSKnUR5nURU5nU$![a URS5nU$f=f)z>Fetch local runtime ip address. Returns: str: IP address rN localhost)socket gethostname gethostbyname Exception)rKr4 public_ips r(rBrBLsY     D6((.   6((5 6s)AAcz^\rSrSr%Sr\\\S'Sr\\S'\\\S'\\\S'S\ 4U4S jjr S \ S S 4S jr S(S\S\ S\S\S\\S\\S\\\ 4S\S\S S 4SjjrS(S\S\ S\S\S\\S\\S\\\ 4S\S\S S 4SjjrS\S \\\\\ 444SjrS\S \\\\\ 444SjrS(S\S \4Sjjr\S)S\S\S\S \\S!\S \\4 S"jj5r\S \S#\\S S 4S$j5r\S)S\S\S\S \\S!\S \ 4 S%jj5rS(S\S\ S\S\S\\S\\S\\\ 4S\S\S \4S&jjr S'r!U=r"$)*PebbloRetrievalAPIWrapper\z!Wrapper for Pebblo Retrieval API.api_keylocalclassifier_locationclassifier_url cloud_urlkwargsc >[USSS5US'[USS[5US'[USS[5US'[TU]"S 0UD6 g) z%Validate that api key in environment.rSPEBBLO_API_KEYrVPEBBLO_CLASSIFIER_URLrWPEBBLO_CLOUD_URLNr)r _DEFAULT_CLASSIFIER_URL_DEFAULT_PEBBLO_CLOUD_URLsuper__init__)selfrX __class__s r(ra"PebbloRetrievalAPIWrapper.__init__hsh0 I/ y$8 $&=?V$  3 K!35N { "6"r'appr)NcTSnURSS9nURS:XaKUR5nUR[R R 3nURSXTU5nUR(aURSS9nU(aB[R"UR5RS5nURSU05 URS[05 UR[R R 3nURSXtU5ngg) zk Send app discovery request to Pebblo server & cloud. Args: app (App): App instance to be discovered. NT exclude_unsetrTPOST cloud_requestpebblo_server_versionpebblo_client_version)dictrU _make_headersrVrr#value make_requestrSjsonloadstextr=updatePLUGIN_VERSIONrW) rbre pebblo_resppayloadheadersapp_discover_urlrlpebblo_cloud_url_s r(send_app_discover+PebbloRetrievalAPIWrapper.send_app_discoverus (((.  # #w .((*G&&'(E(E(K(K'LM ++F4DwWK <<((t(.>.@.D.DZQS.T +1<1A1A1C1G1G!12 .//r'cR# SU0n0SS.nSnURS:XaUR5nUR[RR 3nUR SXeU5IShvN nU(a*URS05US'URS S5US 'XC4$N87f) rr$rrTrTriNrr)rUrorVrr%rprr=rs r(acheck_prompt_validity0PebbloRetrievalAPIWrapper.acheck_prompt_validity0s"#H--/ B $  # #w .((*G&&'(@(@(F(F'GH !% 2 2*^!K.9ooj".M +1<PQ1R .// sA*B',B%-9B'rkcSSS.nU(aEUR(aURSUR05 U$[RS5 U$)z Generate headers for the request. args: cloud_request (bool): flag indicating whether the request is for Pebblo cloud. returns: dict: Headers for the request. zapplication/json)Acceptz Content-Typez x-api-keyz,API key is missing for Pebblo cloud request.)rSrurDr)rbrkrys r(ro'PebbloRetrievalAPIWrapper._make_headersQsM).  || T\\:;MNr'methodurlryrxtimeoutc H[XX#US9n[RSUURR[ [ URR (aURR O/55[ UR55 UR[R:a$[RSUR35 U$UR[R:a$[RSUR35 U$UR[R:wa"[RSUR35 U$![a [RSU5 g[a n[RSU5 SnAgSnAff=f) a Make a request to the Pebblo server/cloud API. Args: method (str): HTTP method (GET, POST, PUT, DELETE, etc.). url (str): URL for the request. headers (dict): Headers for the request. payload (Optional[dict]): Payload for the request (for POST, PUT, etc.). timeout (int): Timeout for the request in seconds. Returns: Optional[Response]: Response object if the request is successful. )rrryrrrz5Request: method %s, url %s, len %s response status %sPebblo Server: Error $Pebblo received an invalid payload: -Pebblo returned an unexpected response code: Unable to reach server %sz'An Exception caught in make_request: %sN)rrDrErstrlenbody status_coderINTERNAL_SERVER_ERRORr BAD_REQUESTrtOKrrN)rrryrxrresponsees r(rq&PebbloRetrievalAPIWrapper.make_requesths`* IwH LLG  $$C1A1A1F1F((--BOPH(()  ##z'G'GG!6x7K7K6LMNO%%)?)??!Ehmm_UVO %%6C++,. O = NN6 < I NNDa H H Is,CEAEAE F!8 F!FF!rwcU(aURS05nURURS05RS055 URSS5 URS05nURURS05RS055 URSS5 URS/5nUHnURSS5 M g0US'0US'/US'g)z Update the payload with response, prompt and context from Pebblo response. Args: payload (dict): Payload to be updated. pebblo_resp (Optional[dict]): Response from Pebblo server. rretrieval_datadataNr$contextdoc)r=rupop)rxrwrr$r context_datas r(r.PebbloRetrievalAPIWrapper.update_cloud_payloads {{:r2H OOKOO,x>O'PQ!J,B,BBB8==/R"JMM9K'/1+3--/$9M%/.(! )/$%:%/..(!  = NN6 < J NNEq I I JsG"FEFE)EE)CE E E ! E),E -E)1 F<E'=FGFE) E  E) E$ E E$ E)'F)F/E2 0 F<FGF G$G& G/G G GGc x[UUV s/sHn [U [5(dM[U RR SU RR S55U R URRRU RR S5S9PM sn [UUR S05UR SS5U S9[US 9UU(a UROS U(a[US 5(a URO/URS 9n U RS S9$s sn f)ac Build the QA payload for the prompt. Args: app_name (str): Name of the app. retriever (VectorStoreRetriever): Retriever instance. question (str): Question asked in the prompt. answer (str): Answer generated by the model. auth_context (Optional[AuthContext]): Authentication context. docs (List[Document]): List of documents retrieved. prompt_entities (Dict[str, Any]): Entities present in the prompt. prompt_time (str): Time when the prompt was generated. prompt_gov_enabled (bool): Whether prompt governance is enabled. Returns: dict: The QA payload for the prompt. full_pathsource pb_checksum)retrieved_fromr vector_dbrrrr)rrrr)rr1 user_auth)r-rr$rruseruser_identitiesrUTrg)r isinstancer rmetadatar= page_content vectorstorercrruser_idhasattrrrUrn) rbrrrrrrrrrrqas r(r1PebbloRetrievalAPIWrapper.build_prompt_qa_payloads#:   Cc8,#&<<#3#3#S\\%5%5h%?$(('33==FF # 0 0 ?   (,,Z<+// qA#5  (#)5%%9 k B B)22 $ 8 85 8wwTw**5 s D7 BD7 r)F)N)#rrr r!r"rr__annotations__rUrrarr}rrrr rboolrrr rrrnro staticmethodintrrqrrrr& __classcell__)rcs@r(rQrQ\s7+ c]"&&ISM!&}! # #NSNTNR$);V;V(;V ;V  ;V {+ ;V8n;Vc3h;V;V!;V ;VN$)<V<V(<V <V  <V {+ <V8n<Vc3h<V<V!<V <V|0c0eD$sCx.rs  33!-65<&0   8 $110S$0U9g-.>   B+ B+r'