>'h{ddlZddlZddlmZddlmZddlmZm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZ ddlZej>jAdre!ddl"m#ZejHejJdZ&GddZ'GddZ(y#e!$rddlZY=wxYw)N)JSONDecodeError)ApiError)AsyncClientWrapperSyncClientWrapper)jsonable_encoder)remove_none_from_dict)UnprocessableEntityError)CompositeRetrievalMode)CompositeRetrievalResult)HttpValidationError) ReRankConfig) Retriever)RetrieverCreate)RetrieverPipelinez1..ceZdZdefdZdddddej edej edej edeje fd Z ddd dej edej ed e de fd Z ddd dej edej ed e de fd Z ddd dedej edej ede fdZeeddedej edej ejede fdZdeddfdZeeeddedej edej edej ededef dZddeeeeddej edej edej edej edej ededej ejedefdZy)RetrieversClientclient_wrapperc||_yN_client_wrapperselfrs n/home/kushmeetdev/Regenta/Chatbot/venv/lib/python3.12/site-packages/llama_cloud/resources/retrievers/client.py__init__zRetrieversClient.__init__! -Nname project_idorganization_idr r!r"returnc |jjjdtjj |jj ddt|||d|jjd}d|jcxkrdkr  )'' -# -((Y)?AQR R  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss E+E-r!r"r5c |jjjdtjj |jj ddt||dt||jjd}d|jcxkrdkr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| #t"$r"t%|j|j& wxYw) a  Create a new Retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - request: RetrieverCreate. --- from llama_cloud import RetrieverCreate from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.create_retriever( request=RetrieverCreate( name="string", ), ) POSTr&r'rEr(r*r?r+r,r-r.r/r0rr4r5r6r7r8r9r rr:r1r;r<rr?r r rrr@rr!r"r5rBrCs rcreate_retrieverz!RetrieversClient.create_retrieverMs0:((55==  LL D$8$8$E$E$G#H!JL_ `( Wf)gh!'*((446 >  )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R S D::+E%c |jjjdtjj |jj ddt||dt||jjd}d|jcxkrdkr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| #t"$r"t%|j|j& wxYw) a  Upsert a new Retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - request: RetrieverCreate. --- from llama_cloud import RetrieverCreate from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.upsert_retriever( request=RetrieverCreate( name="string", ), ) PUTr&r'rEr(rHr-r.r/r0rIrJs rupsert_retrieverz!RetrieversClient.upsert_retriever|s0:((55==  LL D$8$8$E$E$G#H!JL_ `( Wf)gh!'*((446 >  )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R SrL retriever_idc |jjjdtjj |jj dd|t||d|jjd}d|jcxkrdkr+nn(tjt|jS|jd k(r1ttjt|j |j}t#|j| #t $r"t#|j|j$ wxYw) a Get a Retriever by ID. Parameters: - retriever_id: str. - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. --- from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.get_retriever( retriever_id="string", ) r%r&api/v1/retrievers/rEr(r)r-r.r/r0rr4r5r6r7r8r9r r:r1r;r<rr?r r rrr@rrPr!r"rBrCs r get_retrieverzRetrieversClient.get_retrievers14((55==  LL D$8$8$E$E$G#H!JN`am`nLo p( Wf)gh((446 >  )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss D33+Er pipelinesrWci}|tur||d<|tur||d<|jjjdtj j |jjdd|t||jjd}d|jcxkrd kr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| #t"$r"t%|j|j& wxYw) a Update an existing Retriever. Parameters: - retriever_id: str. - name: typing.Optional[str]. - pipelines: typing.Optional[typing.List[RetrieverPipeline]]. --- from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.update_retriever( retriever_id="string", ) r rWrNr&rRr(r?r+r,r-r.r/r0OMITrr4r5r6r7r8r9rr:r1r;r<rr?r r rrr@rrPr rW_requestrBrCs rupdate_retrieverz!RetrieversClient.update_retrieversT424 t #HV  D $-H[ !((55==  LL D$8$8$E$E$G#H!JN`am`nLo p!(+((446 >  )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss %E +E7cV|jjjdtjj |jj dd||jjd}d|jcxkrdkry|jd k(r1ttjt|j |j}t|j| #t$r"t|j|j wxYw) a@ Delete a Retriever by ID. Parameters: - retriever_id: str. --- from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.delete_retriever( retriever_id="string", ) DELETEr&rRr(r+r,r-r.Nr/r0rr4r5r6r7r8r9r:r1r r;r<r r?rrr@rrPrBrCs rdelete_retrieverz!RetrieversClient.delete_retrievers ((55==  LL D$8$8$E$E$G#H!JN`am`nLo p((446 > )'' -# -  .  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss C==+D(mode rerank_top_n rerank_configrfrgrhqueryc d|i}|tur||d<|tur||d<|tur||d<|jjjdtj j |jjdd|dt||jjd }d |jcxkrd kr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j|#t"$r"t%|j|j&wxYw)a Retrieve data using a Retriever. Parameters: - retriever_id: str. - mode: typing.Optional[CompositeRetrievalMode]. The mode of composite retrieval. - rerank_top_n: typing.Optional[int]. - rerank_config: typing.Optional[ReRankConfig]. The rerank configuration for composite retrieval. - query: str. The query to retrieve against. --- from llama_cloud import CompositeRetrievalMode, ReRankConfig, ReRankerType from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.retrieve( retriever_id="string", mode=CompositeRetrievalMode.ROUTING, rerank_config=ReRankConfig( type=ReRankerType.SYSTEM_DEFAULT, ), query="string", ) rirfrgrhrGr&rR /retriever(rYr-r.r/r0r[rr4r5r6r7r8r9rr:r1r;r<r r?r r rrr@ rrPrfrgrhrir]rBrCs rretrievezRetrieversClient.retrieve&stL3:51A t #HV  t #'3H^ $  $(5H_ %((55==  LL ''4467q9=OP\~]f;g "(+((446>  )'' -# -(()A9>>CST T  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss 5E+Fr!r"rfrgrhrWc @d|i}|tur||d<|tur||d<|tur||d<|tur||d<|jjjdtj j |jjddt||d t||jjd } d | jcxkrd kr+nn(tjt| jS| jdk(r1t!tjt"| j | j} t'| j| #t$$r"t'| j| j(wxYw)aK Retrieve data using specified pipelines without creating a persistent retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - mode: typing.Optional[CompositeRetrievalMode]. The mode of composite retrieval. - rerank_top_n: typing.Optional[int]. - rerank_config: typing.Optional[ReRankConfig]. The rerank configuration for composite retrieval. - query: str. The query to retrieve against. - pipelines: typing.Optional[typing.List[RetrieverPipeline]]. The pipelines to use for retrieval. --- from llama_cloud import CompositeRetrievalMode, ReRankConfig, ReRankerType from llama_cloud.client import LlamaCloud client = LlamaCloud( token="YOUR_TOKEN", ) client.retrievers.direct_retrieve( mode=CompositeRetrievalMode.ROUTING, rerank_config=ReRankConfig( type=ReRankerType.SYSTEM_DEFAULT, ), query="string", ) rirfrgrhrWrGr&api/v1/retrievers/retrieverEr(rHr-r.r/r0r[rr4r5r6r7r8r9r rr:r1r;r<r r?r r rrr@ rr!r"rfrgrhrirWr]rBrCs rdirect_retrievez RetrieversClient.direct_retrievefsV3:51A t #HV  t #'3H^ $  $(5H_ % D $-H[ !((55==  LL D$8$8$E$E$G#H!JLh i( Wf)gh!(+((446 >  )'' -# -(()A9>>CST T  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN Sy'<'<9>>R R Ss E22+F)__name__ __module__ __qualname__rrr=Optionalstrr>rrDrrKrOrUr[rr^rdr intrr rnrtrrrr s.*;. &*+/04 'Oooc"'OOOC( 'O  - 'O Y  'OX,004 -OOOC(-O - -O ! -O  -Od,004 -OOOC(-O - -O ! -O  -Of,004 )O)OOOC( )O  - )O  )O^&*EI .O.Oooc" .O ??6;;/@#AB .O  .O`OSOTOH9=-17; >O>Ooo45 >O ooc* >O |4 >O>O ">OF,0048<-17;EIDOOOC(DO - DO oo45 DO ooc* DO|4DODO??6;;/@#ABDO "DOrrceZdZdefdZdddddej edej edej edeje fd Z ddd dej edej ed e de fd Z ddd dej edej ed e de fd Z ddd dedej edej ede fdZeeddedej edej ejede fdZdeddfdZeeeddedej edej edej ededef dZddeeeeddej edej edej edej edej ededej ejedefdZy)AsyncRetrieversClientrc||_yrrrs rrzAsyncRetrieversClient.__init__rrNrr r!r"r#c K|jjjdtjj |jj ddt|||d|jjdd{}d|jcxkrd kr>R R Ss+B E<E BE<%E5E<+E99E<rEr5c K|jjjdtjj |jj ddt||dt||jjdd{}d|jcxkrd kr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| 7#t"$r"t%|j|j& wxYww) a Create a new Retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - request: RetrieverCreate. --- from llama_cloud import RetrieverCreate from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.create_retriever( request=RetrieverCreate( name="string", ), ) rGr&r'rEr(rHNr-r.r/r0rIrJs rrKz&AsyncRetrieversClient.create_retrievers>:..;;CC  LL D$8$8$E$E$G#H!JL_ `( Wf)gh!'*((446 D   )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN!  Sy'<'<9>>R R S+BE4EBE4E-E4+E11E4c K|jjjdtjj |jj ddt||dt||jjdd{}d|jcxkrd kr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| 7#t"$r"t%|j|j& wxYww) a Upsert a new Retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - request: RetrieverCreate. --- from llama_cloud import RetrieverCreate from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.upsert_retriever( request=RetrieverCreate( name="string", ), ) rNr&r'rEr(rHNr-r.r/r0rIrJs rrOz&AsyncRetrieversClient.upsert_retriever s>:..;;CC  LL D$8$8$E$E$G#H!JL_ `( Wf)gh!'*((446 D   )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN!  Sy'<'<9>>R R SrrPc K|jjjdtjj |jj dd|t||d|jjdd{}d|jcxkrd kr+nn(tjt|jS|jd k(r1ttjt|j |j}t#|j| 7#t $r"t#|j|j$ wxYww) a Get a Retriever by ID. Parameters: - retriever_id: str. - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. --- from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.get_retriever( retriever_id="string", ) r%r&rRrEr(r)Nr-r.r/r0rSrTs rrUz#AsyncRetrieversClient.get_retriever8s?4..;;CC  LL D$8$8$E$E$G#H!JN`am`nLo p( Wf)gh((446 D   )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN  Sy'<'<9>>R R Ss+BE-D=BE-D?&E-?+E**E-rVrWcKi}|tur||d<|tur||d<|jjjdtj j |jjdd|t||jjdd{}d |jcxkrd kr+nn(tjt|jS|jd k(r1ttjt |j |j}t%|j| 7#t"$r"t%|j|j& wxYww) a Update an existing Retriever. Parameters: - retriever_id: str. - name: typing.Optional[str]. - pipelines: typing.Optional[typing.List[RetrieverPipeline]]. --- from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.update_retriever( retriever_id="string", ) r rWrNr&rRr(rYNr-r.r/r0rZr\s rr^z&AsyncRetrieversClient.update_retrievercsb424 t #HV  D $-H[ !..;;CC  LL D$8$8$E$E$G#H!JN`am`nLo p!(+((446 D   )'' -# -((INN4DE E  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN  Sy'<'<9>>R R Ss+B'F)E*BF/E?F+FFcrK|jjjdtjj |jj dd||jjdd{}d|jcxkrdkry|jd k(r1ttjt|j |j}t|j| 7#t$r"t|j|j wxYww) aP Delete a Retriever by ID. Parameters: - retriever_id: str. --- from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.delete_retriever( retriever_id="string", ) r`r&rRr(raNr-r.r/r0rbrcs rrdz&AsyncRetrieversClient.delete_retrievers ..;;CC  LL D$8$8$E$E$G#H!JN`am`nLo p((446 D  )'' -# -  .  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN  Sy'<'<9>>R R Ss+BD7DAD7 D 0D7 +D44D7rerfrgrhric 0Kd|i}|tur||d<|tur||d<|tur||d<|jjjdtj j |jjdd|dt||jjd d {}d |jcxkrd kr+nn(tjt|jS|jdk(r1ttjt |j |j}t%|j|7#t"$r"t%|j|j&wxYww)a Retrieve data using a Retriever. Parameters: - retriever_id: str. - mode: typing.Optional[CompositeRetrievalMode]. The mode of composite retrieval. - rerank_top_n: typing.Optional[int]. - rerank_config: typing.Optional[ReRankConfig]. The rerank configuration for composite retrieval. - query: str. The query to retrieve against. --- from llama_cloud import CompositeRetrievalMode, ReRankConfig, ReRankerType from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.retrieve( retriever_id="string", mode=CompositeRetrievalMode.ROUTING, rerank_config=ReRankConfig( type=ReRankerType.SYSTEM_DEFAULT, ), query="string", ) rirfrgrhrGr&rRrkr(rYNr-r.r/r0rlrms rrnzAsyncRetrieversClient.retrievesL3:51A t #HV  t #'3H^ $  $(5H_ %..;;CC  LL ''4467q9=OP\~]f;g "(+((446D   )'' -# -(()A9>>CST T  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN#  Sy'<'<9>>R R Ss+B7F9E&:BF?E(F(+FFroc \Kd|i}|tur||d<|tur||d<|tur||d<|tur||d<|jjjdtj j |jjddt||d t||jjd d {} d | jcxkrdkr+nn(tjt| jS| jdk(r1t!tjt"| j | j} t'| j| 7#t$$r"t'| j| j(wxYww)a[ Retrieve data using specified pipelines without creating a persistent retriever. Parameters: - project_id: typing.Optional[str]. - organization_id: typing.Optional[str]. - mode: typing.Optional[CompositeRetrievalMode]. The mode of composite retrieval. - rerank_top_n: typing.Optional[int]. - rerank_config: typing.Optional[ReRankConfig]. The rerank configuration for composite retrieval. - query: str. The query to retrieve against. - pipelines: typing.Optional[typing.List[RetrieverPipeline]]. The pipelines to use for retrieval. --- from llama_cloud import CompositeRetrievalMode, ReRankConfig, ReRankerType from llama_cloud.client import AsyncLlamaCloud client = AsyncLlamaCloud( token="YOUR_TOKEN", ) await client.retrievers.direct_retrieve( mode=CompositeRetrievalMode.ROUTING, rerank_config=ReRankConfig( type=ReRankerType.SYSTEM_DEFAULT, ), query="string", ) rirfrgrhrWrGr&rqrEr(rHNr-r.r/r0rrrss rrtz%AsyncRetrieversClient.direct_retrievesV3:51A t #HV  t #'3H^ $  $(5H_ % D $-H[ !..;;CC  LL D$8$8$E$E$G#H!JLh i( Wf)gh!(+((446 D   )'' -# -(()A9>>CST T  C '*8+@+@ATV_VdVdVf+gh h S&^^-N9#8#8~NN!  Sy'<'<9>>R R Ss+C F,E<BF,E>%F,>+F))F,)rurvrwrrr=rxryr>rrDrrKrOrUr[rr^rdr rzrr rnrtr{rrr}r}s.*<. &*+/04 'Oooc"'OOOC( 'O  - 'O Y  'OX,004 -OOOC(-O - -O ! -O  -Od,004 -OOOC(-O - -O ! -O  -Of,004 )O)OOOC( )O  - )O  )O^&*EI .O.Oooc" .O ??6;;/@#AB .O  .O`O3O4OH9=-17; >O>Ooo45 >O ooc* >O |4 >O>O ">OF,0048<-17;EIDOOOC(DO - DO oo45 DO ooc* DO|4DODO??6;;/@#ABDO "DOrr}))r= urllib.parser6 json.decoderrcore.api_errorrcore.client_wrapperrrcore.jsonable_encoderrcore.remove_none_from_dictr !errors.unprocessable_entity_errorr types.composite_retrieval_moder types.composite_retrieval_resultr types.http_validation_errorr types.re_rank_configrtypes.retrieverrtypes.retriever_creatertypes.retriever_pipelinerr; __version__ startswith ImportError pydantic.v1v1castAnyr[rr}r{rrrs(&H5?IDH>0(59&&t," v{{6::s#JOJOZ JOJOi s'B33 B?>B?