
    iR                       S SK r S SKrS SKJr  SSKJr  SSKJrJ	r	  SSK
Jr  SSKJr  SSKJr  SS	KJr  SS
KJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSK J!r!  SSK"J#r#  SSK$J%r%  SSK&J'r'  SSK(J)r)  SSK*J+r+  SSK,J-r-  SSK.J/r/  SSK0J1r1  SSK2J3r3  SSK4J5r5  SSK6J7r7  SSK8J9r9  SSK:J;r;  SSK<J=r=  SS K>J?r?  SS!K@JArA  SS"KBJCrC  SS#KDJErE  S$S%KFJGrG  S$S&KHJIrI  S$S'KJJKrK  S$S(KLJMrM   S SKNrN\NR                  R                  S)5      (       a  \QeS SKRJSrN  \ R                  " \ R                  S*5      rV " S+ S,5      rW " S- S.5      rXg! \Q a    S SKNrN N>f = f)/    N)JSONDecodeError   )ApiError)AsyncClientWrapperSyncClientWrapper)jsonable_encoder)remove_none_from_dict)UnprocessableEntityError)ChatData)CloudDocument)CloudDocumentCreate)DataSinkCreate)EvalExecutionParams)FileCountByStatusResponse)HttpValidationError)InputMessage)LlamaParseParameters)ManagedIngestionStatusResponse)MetadataFilters)#PaginatedListCloudDocumentsResponse)"PaginatedListPipelineFilesResponse)Pipeline)PipelineCreate)PipelineDataSource)PipelineDataSourceCreate)PipelineDeployment)PipelineFile)PipelineFileCreate)PipelineMetadataConfig)PipelineType)PlaygroundSession)PresetRetrievalParams)RetrievalMode)RetrieveResults)TextNode   )%PipelineFileUpdateCustomMetadataValue)PipelineUpdateEmbeddingConfig)PipelineUpdateTransformConfig)0RetrievalParamsSearchFiltersInferenceSchemaValuez1..c            '       N   \ rS rSrS\4S jrSSSSSS.S\R                  \   S\R                  \   S\R                  \   S	\R                  \	   S
\R                  \   S\R                  \   4S jjrSSS.S\R                  \   S
\R                  \   S\S\4S jjrSSS.S\R                  \   S
\R                  \   S\S\4S jjrS\S\4S jr\\\\\\\\\\\\S.S\S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\4S  jjrS\SS4S! jrS\S\4S" jrS\S\4S# jrS\S\4S$ jrS\SS4S% jrS\S\4S& jr SSS'.S\S(\R                  \   S)\R                  \!   S\R                  \"   4S* jjr#S\S\R                  \$   S\R                  \"   4S+ jr%SSSSSS,.S\S(\R                  \   S)\R                  \!   S-\R                  \&   S.\R                  \&   S/\R                  \   S\'4S0 jjr(SSS'.S\S(\R                  \   S)\R                  \!   S\)4S1 jjr*S2\S\S\4S3 jr+\S4.S2\S\S5\R                  \RX                  \\R                  \-   4      S\"4S6 jjr.S2\S\SS4S7 jr/S\S8\R`                  S\RX                  \\4   4S9 jr1S\SS4S: jr2S\S\R                  \3   4S; jr4S\S\R                  \5   S\R                  \3   4S< jr6\S=.S(\S\S>\R                  \7   S\34S? jjr8S(\S\SS4S@ jr9S(\S\S\4SA jr:S(\S\S\4SB jr;SS\\\\\\\\\\\\\\SC.S\S\R                  \   S
\R                  \   SD\R                  \&   SE\R                  \7   SF\R                  \&   SG\R                  \!   SH\R                  \&   SI\R                  \7   SJ\R                  \<   SK\R                  \RX                  \\R                  \=   4      SL\R                  \&   SM\R                  \>   SN\R                  \!   SO\R                  \!   SP\R                  \!   SQ\SR\R                  \   S\?4&SS jjr@S\S\R                  \A   4ST jrBSU\S\S\A4SV jrCS\S\D4SW jrE\\\SX.S\SY\R                  \R                  \F      SZ\R                  \G   SR\R                  \   S\R                  4
S[ jjrISSSSSS\.S\S]\R                  \&   S-\R                  \&   S2\R                  \   S^\R                  \!   S_\R                  \!   S\R                  \J   4S` jjrKS\S\R                  \L   S\R                  \J   4Sa jrMS\S\R                  \L   S\R                  \J   4Sb jrNSSSSSS\.S\S]\R                  \&   S-\R                  \&   S2\R                  \   S^\R                  \!   S_\R                  \!   S\O4Sc jjrPSd\S\S\J4Se jrQSd\S\SS4Sf jrRSd\S\S\4Sg jrSSd\S\S\R                  \T   4Sh jrUSirVg)jPipelinesClient:   client_wrapperc                    Xl         g N_client_wrapperselfr.   s     `/home/james-whalen/.local/lib/python3.13/site-packages/llama_cloud/resources/pipelines/client.py__init__PipelinesClient.__init__;       -    N
project_idproject_namepipeline_namepipeline_typeorganization_idr;   r<   r=   r>   r?   returnc                   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        UUUUUS.5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US
9e! [$         a    ['        UR                  UR(                  S
9ef = f)a  
Search for pipelines by various parameters.

Parameters:
    - project_id: typing.Optional[str].

    - project_name: typing.Optional[str].

    - pipeline_name: typing.Optional[str].

    - pipeline_type: typing.Optional[PipelineType].

    - organization_id: typing.Optional[str].
---
from llama_cloud import PipelineType
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.search_pipelines(
    pipeline_type=PipelineType.PLAYGROUND,
)
GET/api/v1/pipelinesr:   <   paramsheaderstimeout   ,    status_codebodyr2   httpx_clientrequesturllibparseurljoinget_base_urlr	   get_headersrN   pydanticparse_obj_astypingListr   jsonr
   r   r   r   textr4   r;   r<   r=   r>   r?   	_response_response_jsons           r5   search_pipelines PipelinesClient.search_pipelines>   sB   B ((55==LL  D$8$8$E$E$G#H!JL^_(",$0%2%2'6 ((446 > 
	 )''-#-((X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   E )E,r;   r?   rR   c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        XS.5      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US
9e! ["         a    [%        UR                  UR&                  S
9ef = f)
Create a new pipeline for a project.

Parameters:
    - project_id: typing.Optional[str].

    - organization_id: typing.Optional[str].

    - request: PipelineCreate.
POSTrC   rD   rd   rE   rG   r\   rH   rI   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   r   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   r;   r?   rR   r_   r`   s         r5   create_pipelinePipelinesClient.create_pipelinex   s-   " ((55==LL  D$8$8$E$E$G#H!JL^_(
)gh!'*((446 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D8 8)E!c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        XS.5      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US
9e! ["         a    [%        UR                  UR&                  S
9ef = f)  
Upsert a pipeline for a project.
Updates if a pipeline with the same name and project_id already exists. Otherwise, creates a new pipeline.

Parameters:
    - project_id: typing.Optional[str].

    - organization_id: typing.Optional[str].

    - request: PipelineCreate.
PUTrC   rD   rd   rE   rh   rJ   rK   rL   rM   ri   rj   s         r5   upsert_pipelinePipelinesClient.upsert_pipeline   s-   $ ((55==LL  D$8$8$E$E$G#H!JL^_(
)gh!'*((446 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Srm   pipeline_idc                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US	9e! [         a    [!        UR                  UR"                  S	9ef = f)
P
Get a pipeline by ID for a given project.

Parameters:
    - pipeline_id: str.
rB   rC   api/v1/pipelines/rE   rH   rI   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   rs   r_   r`   s       r5   get_pipelinePipelinesClient.get_pipeline   s#    ((55==LL  D$8$8$E$E$G#H!JN_`k_lLmn((446	 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   D% %)Eembedding_configtransform_configdata_sink_idembedding_model_config_id	data_sinkpreset_retrieval_parameterseval_parametersllama_parse_parametersstatusmetadata_confignamemanaged_pipeline_idr}   r~   r   r   r   r   r   r   r   r   r   r   c                   0 nU[         La  X.S'   U[         La  X>S'   U[         La  XNS'   U[         La  X^S'   U[         La  XnS'   U[         La  X~S'   U[         La  XS'   U	[         La  XS'   U
[         La  XS	'   U[         La  XS
'   U[         La  XS'   U[         La  XS'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU 35      [        U5      U R                  R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e! ["         a    [%        UR                  UR&                  S9ef = f)*  
Update an existing pipeline for a project.

Parameters:
    - pipeline_id: str.

    - embedding_config: typing.Optional[PipelineUpdateEmbeddingConfig].

    - transform_config: typing.Optional[PipelineUpdateTransformConfig]. Configuration for the transformation.

    - data_sink_id: typing.Optional[str].

    - embedding_model_config_id: typing.Optional[str].

    - data_sink: typing.Optional[DataSinkCreate].

    - preset_retrieval_parameters: typing.Optional[PresetRetrievalParams].

    - eval_parameters: typing.Optional[EvalExecutionParams].

    - llama_parse_parameters: typing.Optional[LlamaParseParameters].

    - status: typing.Optional[str].

    - metadata_config: typing.Optional[PipelineMetadataConfig].

    - name: typing.Optional[str].

    - managed_pipeline_id: typing.Optional[str].
r}   r~   r   r   r   r   r   r   r   r   r   r   rp   rC   rv   rE   r\   rH   rI   rJ   rK   rL   rM   OMITr2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   rs   r}   r~   r   r   r   r   r   r   r   r   r   r   _requestr_   r`   s                    r5   update_existing_pipeline(PipelinesClient.update_existing_pipeline   s   ^ 244'+;'(4'+;'(t#'3^$$D04M01D $-[!&d26Q23$&*9&'!-1G-.!'X$&*9&'t#Vd*.A*+((55==LL  D$8$8$E$E$G#H!JN_`k_lLmn!(+((446 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   )G )G6c                 P   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g  UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US
9e! [         a    [        UR                  UR                   S
9ef = f)z
Delete a pipeline by ID.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.delete_pipeline(
    pipeline_id="string",
)
DELETErC   rv   rE   rw   rJ   rK   NrL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   r
   rX   rY   r   r\   r   r   r]   ry   s       r5   delete_pipelinePipelinesClient.delete_pipeline/  s     ((55==LL  D$8$8$E$E$G#H!JN_`k_lLmn((446	 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   C< <)D%c           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)z
Get the status of a pipeline by ID.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_status(
    pipeline_id="string",
)
rB   rC   rv   /statusrE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   ry   s       r5   get_pipeline_status#PipelinesClient.get_pipeline_statusO  s'     ((55==LL  D$8$8$E$E$G#H!JN_`k_llsLtu((446	 > 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D& &)Ec           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)
Run ingestion for the pipeline by incrementally updating the data-sink with upstream changes from data-sources & files.

Parameters:
    - pipeline_id: str.
rg   rC   rv   /syncrE   rw   rJ   rK   rL   rM   rx   ry   s       r5   sync_pipelinePipelinesClient.sync_pipelineo  &    ((55==LL  D$8$8$E$E$G#H!JN_`k_llqLrs((446	 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)%
Parameters:
    - pipeline_id: str.
rg   rC   rv   /sync/cancelrE   rw   rJ   rK   rL   rM   rx   ry   s       r5   cancel_pipeline_sync$PipelinesClient.cancel_pipeline_sync  s)   
 ((55==LL  ''4467q9=N{m[g;h ((446 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c           	      R   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g	  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e! [         a    [        UR                  UR                   S9ef = f)z
Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.force_delete_pipeline(
    pipeline_id="string",
)
rg   rC   rv   /force-deleterE   rw   rJ   rK   NrL   rM   r   ry   s       r5   force_delete_pipeline%PipelinesClient.force_delete_pipeline  s    ((55==LL  ''4467q9=N{m[h;i ((446 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   C= =)D&c           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)=
Copy a pipeline by ID.

Parameters:
    - pipeline_id: str.
rg   rC   rv   /copyrE   rw   rJ   rK   rL   rM   rx   ry   s       r5   copy_pipelinePipelinesClient.copy_pipeline  r   r   data_source_idonly_manually_uploadedr   r   c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        X#S.5      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e! [$         a    ['        UR                  UR(                  S9ef = f)aC  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_files(
    pipeline_id="string",
)
rB   rC   rv   /filesr   rE   rF   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   r4   rs   r   r   r_   r`   s         r5   list_pipeline_files#PipelinesClient.list_pipeline_files  s?   4 ((55==LL  D$8$8$E$E$G#H!JN_`k_llrLst(#1d ((446 > 
	 )''-#-((\)BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Src   c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US
9e! [$         a    ['        UR                  UR(                  S
9ef = f)a&  
Add files to a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[PipelineFileCreate].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.add_files_to_pipeline_api(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   r   rE   r   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   r4   rs   rR   r_   r`   s        r5   add_files_to_pipeline_api)PipelinesClient.add_files_to_pipeline_api  s7   * ((55==LL  D$8$8$E$E$G#H!JN_`k_llrLst!'*((446 > 
	 )''-#-((\)BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   E )E*r   r   limitoffsetorder_byr   r   r   c                   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e! [          a    [#        UR                  UR$                  S9ef = f)a  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].

    - limit: typing.Optional[int].

    - offset: typing.Optional[int].

    - order_by: typing.Optional[str].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_files_2(
    pipeline_id="string",
)
rB   rC   rv   /files2r   rE   rF   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   	r4   rs   r   r   r   r   r   r_   r`   s	            r5   list_pipeline_files_2%PipelinesClient.list_pipeline_files_2'  sF   F ((55==LL  D$8$8$E$E$G#H!JN_`k_llsLtu(&4.D"$ ( ((446 > 
	 )''-#-(()KY^^M]^^  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D6 6)Ec          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        X#S.5      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e! [          a    [#        UR                  UR$                  S9ef = f)aO  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_file_status_counts(
    pipeline_id="string",
)
rB   rC   rv   /files/status-countsr   rE   rF   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r   s         r5   get_pipeline_file_status_counts/PipelinesClient.get_pipeline_file_status_countsc  s:   4 ((55==LL  ''4467q9=N{m[o;p )#1d ((446 > 

	 )''-#-(()BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   D2 2)Efile_idc                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e! [         a    [!        UR                  UR"                  S9ef = f)a  
Get status of a file for a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_file_status(
    file_id="string",
    pipeline_id="string",
)
rB   rC   rv   /files/r   rE   rw   rJ   rK   rL   rM   r   r4   r   rs   r_   r`   s        r5   get_pipeline_file_status(PipelinesClient.get_pipeline_file_status  s3   & ((55==LL  ''4467q9=N{m[bcjbkkr;s ((446 > 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D) ))Ecustom_metadatar   c          
         0 nU[         La  X4S'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU SU 35      [        U5      U R                  R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e! ["         a    [%        UR                  UR&                  S9ef = f)a  
Update a file for a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.

    - custom_metadata: typing.Optional[typing.Dict[str, typing.Optional[PipelineFileUpdateCustomMetadataValue]]].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.update_pipeline_file(
    file_id="string",
    pipeline_id="string",
)
r   rp   rC   rv   r   rE   r   rJ   rK   rL   rM   r   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   r   rs   r   r   r_   r`   s          r5   update_pipeline_file$PipelinesClient.update_pipeline_file  sM   : 24$&*9&'((55==LL  ''4467q9=N{m[bcjbk;l "(+((446 > 
	 )''-#-((y~~7GHH  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c           
      V   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g	  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e! [         a    [        UR                  UR                   S9ef = f)a  
Delete a file from a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.delete_pipeline_file(
    file_id="string",
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   rJ   rK   NrL   rM   r   r   s        r5   delete_pipeline_file$PipelinesClient.delete_pipeline_file  s   & ((55==LL  ''4467q9=N{m[bcjbk;l ((446 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   C? ?)D(upload_filec          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        0 5      SU0U R                   R                  5       SS9nSUR                  s=::  a  S	:  aC  O  O@[        R                  " [        R                  [        [        4   UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e! [$         a    ['        UR                  UR(                  S9ef = f)e
Import metadata for a pipeline.

Parameters:
    - pipeline_id: str.

    - upload_file: typing.IO.
rp   rC   rv   	/metadatar   rE   datafilesrH   rI   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   rZ   Dictstrr\   r
   r   r   r   r]   r4   rs   r   r_   r`   s        r5   import_pipeline_metadata(PipelinesClient.import_pipeline_metadata  sC    ((55==LL  D$8$8$E$E$G#H!JN_`k_lluLvw!"% +.((446 > 
	 )''-#-((S#X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   &E
 
)E3c           	      R   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g	  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e! [         a    [        UR                  UR                   S9ef = f)z
Delete metadata for all files in a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.delete_pipeline_files_metadata(
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   rJ   rK   NrL   rM   r   ry   s       r5   delete_pipeline_files_metadata.PipelinesClient.delete_pipeline_files_metadata*  s     ((55==LL  D$8$8$E$E$G#H!JN_`k_lluLvw((446	 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US
9e! ["         a    [%        UR                  UR&                  S
9ef = f)z
Get data sources for a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_data_sources(
    pipeline_id="string",
)
rB   rC   rv   /data-sourcesrE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   ry   s       r5   list_pipeline_data_sources*PipelinesClient.list_pipeline_data_sourcesJ  s3     ((55==LL  ''4467q9=N{m[h;i ((446 > 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D7 7)E c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US
9e! [$         a    ['        UR                  UR(                  S
9ef = f)a6  
Add data sources to a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[PipelineDataSourceCreate].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.add_data_sources_to_pipeline(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   r   rE   r   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   r   s        r5   add_data_sources_to_pipeline,PipelinesClient.add_data_sources_to_pipelinel  s;   * ((55==LL  ''4467q9=N{m[h;i "'*((446 > 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   sync_intervalr   c          
         0 nU[         La  X4S'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU SU 35      [        U5      U R                  R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e! ["         a    [%        UR                  UR&                  S9ef = f)an  
Update the configuration of a data source in a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.

    - sync_interval: typing.Optional[float].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.update_pipeline_data_source(
    data_source_id="string",
    pipeline_id="string",
)
r   rp   rC   rv   /data-sources/rE   r   rJ   rK   rL   rM   r   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   r   rs   r   r   r_   r`   s          r5   update_pipeline_data_source+PipelinesClient.update_pipeline_data_source  sK   . 24$(5_%((55==LL  ''4467q9#K=~>NO "(+((446 > 	
	 )''-#-(();Y^^=MNN  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c           
      V   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g	  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e! [         a    [        UR                  UR                   S9ef = f)a-  
Delete a data source from a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.delete_pipeline_data_source(
    data_source_id="string",
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   rJ   rK   NrL   rM   r   r4   r   rs   r_   r`   s        r5   delete_pipeline_data_source+PipelinesClient.delete_pipeline_data_source  s   & ((55==LL  ''4467q9#K=~>NO ((446 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e! [         a    [!        UR                  UR"                  S9ef = f)
Run ingestion for the pipeline data source by incrementally updating the data-sink with upstream changes from data-source.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.
rg   rC   rv   r   r   rE   rw   rJ   rK   rL   rM   rx   r  s        r5   sync_pipeline_data_source)PipelinesClient.sync_pipeline_data_source  s/    ((55==LL  ''4467q9#K=~>NeT ((446 > 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e! [         a    [!        UR                  UR"                  S9ef = f)a;  
Get the status of a data source for a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_data_source_status(
    data_source_id="string",
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rw   rJ   rK   rL   rM   r   r  s        r5   get_pipeline_data_source_status/PipelinesClient.get_pipeline_data_source_status  s0   & ((55==LL  ''4467q9#K=~>NgV ((446 > 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   r;   r?   dense_similarity_top_kdense_similarity_cutoffsparse_similarity_top_kenable_rerankingrerank_top_nalphasearch_filterssearch_filters_inference_schemafiles_top_kretrieval_moderetrieve_image_nodesretrieve_page_screenshot_nodesretrieve_page_figure_nodes
class_namer  r  r  r  r  r  r  r  r  r  r  r  r  queryr  c          	      `   SU0nU[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U	[         La  U	US'   U
[         La  U
US'   U[         La  UUS	'   U[         La  UUS
'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU S35      [        X#S.5      [        U5      U R                  R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e! [$         a    ['        UR                  UR(                  S9ef = f)a   
Get retrieval results for a managed pipeline and a query

Parameters:
    - pipeline_id: str.

    - project_id: typing.Optional[str].

    - organization_id: typing.Optional[str].

    - dense_similarity_top_k: typing.Optional[int].

    - dense_similarity_cutoff: typing.Optional[float].

    - sparse_similarity_top_k: typing.Optional[int].

    - enable_reranking: typing.Optional[bool].

    - rerank_top_n: typing.Optional[int].

    - alpha: typing.Optional[float].

    - search_filters: typing.Optional[MetadataFilters].

    - search_filters_inference_schema: typing.Optional[typing.Dict[str, typing.Optional[RetrievalParamsSearchFiltersInferenceSchemaValue]]].

    - files_top_k: typing.Optional[int].

    - retrieval_mode: typing.Optional[RetrievalMode]. The retrieval mode for the query.

    - retrieve_image_nodes: typing.Optional[bool]. Whether to retrieve image nodes.

    - retrieve_page_screenshot_nodes: typing.Optional[bool]. Whether to retrieve page screenshot nodes.

    - retrieve_page_figure_nodes: typing.Optional[bool]. Whether to retrieve page figure nodes.

    - query: str. The query to retrieve against.

    - class_name: typing.Optional[str].
---
from llama_cloud import FilterCondition, MetadataFilters, RetrievalMode
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.run_search(
    pipeline_id="string",
    search_filters=MetadataFilters(
        filters=[],
        condition=FilterCondition.AND,
    ),
    retrieval_mode=RetrievalMode.CHUNKS,
    query="string",
)
r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  rg   rC   rv   	/retrieverd   rE   rh   rJ   rK   rL   rM   r   r2   rQ   rR   rS   rT   rU   rV   r	   r   rW   rN   rX   rY   r$   r\   r
   r   r   r   r]   r4   rs   r;   r?   r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r   r_   r`   s                         r5   
run_searchPipelinesClient.run_search*  sJ   ` 3:51A!-1GH-."$.2IH./"$.2IH./4'+;H'(t#'3H^$ %HW%)7H%&*$6:YH67d"&1H]#%)7H%&t+/CH+,)59WH56%T15OH12T!%/H\"((55==LL  D$8$8$E$E$G#H!JN_`k_lluLvw(
)gh!(+((446 > 
	 )''-#-(()..:JKK  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss    H )H-c           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US
9e! ["         a    [%        UR                  UR&                  S
9ef = f)z
Get jobs for a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_jobs(
    pipeline_id="string",
)
rB   rC   rv   /jobsrE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   ry   s       r5   list_pipeline_jobs"PipelinesClient.list_pipeline_jobs  s0     ((55==LL  D$8$8$E$E$G#H!JN_`k_llqLrs((446	 > 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   job_idc           
         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)a  
Get a job for a pipeline.

Parameters:
    - job_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_job(
    job_id="string",
    pipeline_id="string",
)
rB   rC   rv   /jobs/rE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   r+  rs   r_   r`   s        r5   get_pipeline_job PipelinesClient.get_pipeline_job  s0   & ((55==LL  ''4467q9=N{m[abhai;j ((446 > 
	 )''-#-(();Y^^=MNN  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	S   D( ()Ec           	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)z
Get a playground session for a user and pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_playground_session(
    pipeline_id="string",
)
rB   rC   rv   /playground-sessionrE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   r!   r\   r
   r   r   r   r]   ry   s       r5   get_playground_session&PipelinesClient.get_playground_session  s*     ((55==LL  ''4467q9=N{m[n;o ((446 > 
	 )''-#-(():INN<LMM  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   messagesr   r  r9  r   c          	         0 nU[         La  X%S'   U[         La  X5S'   U[         La  XES'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU S35      [        U5      U R                  R                  5       SS	9nS
UR                  s=::  a  S:  a6  O  O3[        R                  " [        R                  UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e! [$         a    ['        UR                  UR(                  S9ef = f)a  
Make a retrieval query + chat completion for a managed pipeline.

Parameters:
    - pipeline_id: str.

    - messages: typing.Optional[typing.List[InputMessage]].

    - data: typing.Optional[ChatData].

    - class_name: typing.Optional[str].
---
from llama_cloud import (
    ChatData,
    FilterCondition,
    LlmParameters,
    MetadataFilters,
    PresetRetrievalParams,
    RetrievalMode,
    SupportedLlmModelNames,
)
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.chat(
    pipeline_id="string",
    data=ChatData(
        retrieval_parameters=PresetRetrievalParams(
            search_filters=MetadataFilters(
                filters=[],
                condition=FilterCondition.AND,
            ),
            retrieval_mode=RetrievalMode.CHUNKS,
        ),
        llm_parameters=LlmParameters(
            model_name=SupportedLlmModelNames.GPT_4_O,
        ),
    ),
)
r9  r   r  rg   rC   rv   /chatrE   r   rJ   rK   rL   rM   r   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   rZ   Anyr\   r
   r   r   r   r]   r4   rs   r9  r   r  r   r_   r`   s           r5   chatPipelinesClient.chat  sh   d 244#+Z t#VT!%/\"((55==LL  D$8$8$E$E$G#H!JN_`k_llqLrs!(+((446 > 
	 )''-#-((Y^^5EFF  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   ?E# #)Fskipr   r   only_direct_uploadonly_api_data_source_documentsrB  rC  rD  c                   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e! [$         a    ['        UR                  UR(                  S9ef = f)a  
Return a list of documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - skip: typing.Optional[int].

    - limit: typing.Optional[int].

    - file_id: typing.Optional[str].

    - only_direct_upload: typing.Optional[bool].

    - only_api_data_source_documents: typing.Optional[bool].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_documents(
    pipeline_id="string",
)
rB   rC   rv   
/documentsrA  rE   rF   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   	r4   rs   rB  r   r   rC  rD  r_   r`   s	            r5   list_pipeline_documents'PipelinesClient.list_pipeline_documentsZ  sQ   F ((55==LL  ''4467q9=N{m[e;f ) "&*<6T ((446 > 
	" )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   #E )E0c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US
9e! [$         a    ['        UR                  UR(                  S
9ef = f)a;  
Batch create documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[CloudDocumentCreate].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.create_batch_pipeline_documents(
    pipeline_id="string",
    request=[],
)
rg   rC   rv   rF  rE   r   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r   rW   rN   rX   rY   rZ   r[   r   r\   r
   r   r   r   r]   r   s        r5   create_batch_pipeline_documents/PipelinesClient.create_batch_pipeline_documents  s:   * ((55==LL  ''4467q9=N{m[e;f "'*((446 > 
	 )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c          	         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9nSUR                  s=::  a  S:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S	:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US
9e! [$         a    ['        UR                  UR(                  S
9ef = f)aF  
Batch create or update a document for a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[CloudDocumentCreate].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.upsert_batch_pipeline_documents(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   rF  rE   r   rJ   rK   rL   rM   rL  r   s        r5   upsert_batch_pipeline_documents/PipelinesClient.upsert_batch_pipeline_documents  s:   * ((55==LL  ''4467q9=N{m[e;f "'*((446 > 
	 )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c                   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e! [          a    [#        UR                  UR$                  S9ef = f)a  
Return a list of documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - skip: typing.Optional[int].

    - limit: typing.Optional[int].

    - file_id: typing.Optional[str].

    - only_direct_upload: typing.Optional[bool].

    - only_api_data_source_documents: typing.Optional[bool].
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.paginated_list_pipeline_documents(
    pipeline_id="string",
)
rB   rC   rv   /documents/paginatedrA  rE   rF   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   r	   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   rH  s	            r5   !paginated_list_pipeline_documents1PipelinesClient.paginated_list_pipeline_documents  sI   F ((55==LL  ''4467q9=N{m[o;p ) "&*<6T ((446 > 
	" )''-#-(()LinnN^__  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   document_idc           
         U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e! [         a    [!        UR                  UR"                  S
9ef = f)a$  
Return a single document for a pipeline.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_document(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   /documents/rE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   r   r\   r
   r   r   r   r]   r4   rW  rs   r_   r`   s        r5   get_pipeline_document%PipelinesClient.get_pipeline_document&  s/   & ((55==LL  ''4467q9=N{m[fgrfs;t ((446 > 
	 )''-#-((	8HII  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr2  c           
      V   U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9nSUR                  s=::  a  S:  a   g	  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e! [         a    [        UR                  UR                   S9ef = f)a  
Delete a document from a pipeline.
Initiates an async job that will:

1. Delete vectors from the vector store
2. Delete the document from MongoDB after vectors are successfully deleted

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.delete_pipeline_document(
    document_id="string",
    pipeline_id="string",
)
r   rC   rv   rY  rE   rw   rJ   rK   NrL   rM   r   r[  s        r5   delete_pipeline_document(PipelinesClient.delete_pipeline_documentK  s   . ((55==LL  ''4467q9=N{m[fgrfs;t ((446 > 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e! [         a    [!        UR                  UR"                  S9ef = f)a+  
Return a single document for a pipeline.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.get_pipeline_document_status(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   rY  r   rE   rw   rJ   rK   rL   rM   r   r[  s        r5   get_pipeline_document_status,PipelinesClient.get_pipeline_document_statust  s/   & ((55==LL  ''4467q9#K=K=P ((446 > 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Sr   c                    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e! ["         a    [%        UR                  UR&                  S9ef = f)a4  
Return a list of chunks for a pipeline document.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import LlamaCloud

client = LlamaCloud(
    token="YOUR_TOKEN",
)
client.pipelines.list_pipeline_document_chunks(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   rY  /chunksrE   rw   rJ   rK   rL   rM   r2   rQ   rR   rS   rT   rU   rV   rW   rN   rX   rY   rZ   r[   r%   r\   r
   r   r   r   r]   r[  s        r5   list_pipeline_document_chunks-PipelinesClient.list_pipeline_document_chunks  s7   & ((55==LL  ''4467q9#K=K=P ((446 > 
	 )''-#-((X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   D: :)E#r1   )W__name__
__module____qualname____firstlineno__r   r6   rZ   Optionalr   r    r[   r   ra   r   rk   rq   rz   r   r(   r)   r   r"   r   r   r   r   r   r   r   r   r   r   r   boolr   r   r   r   intr   r   r   r   r   r   r'   r   r   IOr   r   r   r   r   r   floatr  r  r  r  r   r*   r#   r$   r$  r   r)  r0  r!   r6  r   r   r=  r?  r   rI  r   rM  rP  r   rU  r\  r_  rb  r%   rg  __static_attributes__ r9   r5   r,   r,   :   s   .*; . ,0-1.27;048O OOC(8O ooc*	8O
 s+8O |48O  -8O 
X	8Oz ,004	!O OOC(!O  -	!O
  !O 
!OL ,004	"O OOC("O  -	"O
  "O 
"OHO O O6 LPKO-1:>59NR@DHL'+CG%)48WOWO !//*GH	WO
 !//*GHWO ooc*WO $*??3#7WO ??>2WO &,__5J%KWO  )<=WO !'0D EWO $WO  )?@WO ooc"WO $__S1WO  
!WOrO3 O4 O@Os O7U O@O O O.O O O.O O O@O O O6 048<+O+O ,	+O
 !' 5+O 
\	"+OZ$O$O,2KK8J,K$O	\	"$OT 048<&*'+)-:O:O ,	:O
 !' 5:O s#:O $:O //#&:O 
,:O@ 048<-O-O ,	-O
 !' 5-O 
#-O^#O #O# #OJh #OX 1O1O 1O
  KKV__-RSST
1O 
1Of#OC #Oc #Od #OJOC O OW]WbWbcfhkckWl O6O# O$ O@ Oc  OfkkJ\>]  OD&O&O,2KK8P,Q&O	'	(&OR ae,O!,O03,OGMW\G],O	,O\$O# $OC $OTX $OLO O# ORZ O8$Oc $OPS $OXv $OT ,0047;:>8<26-1(,;? ,09=6:@D<@+/-}O}O OOC(	}O
  -}O !' 4}O "(!7}O "(!5}O !//$/}O ooc*}O u%}O 8}O *0KKV__-]^^_*
}O  __S)!}O" 6#}O$ %ood3%}O& )/(='}O( %+OOD$9)}O* +}O, OOC(-}O. 
/}O~Oc OfkkBT6U O@#Os #O #OAS #OJ O#  O:K  OL @D*.+/HOHO //&++l";<	HO
 ooh'HO OOC(HO 
HO\ &*&*(,48@D<O<O ooc"	<O
 s#<O %<O #OOD1<O )/(=<O 
]	#<O|&O&O,2KK8K,L&O	]	#&OP&O&O,2KK8K,L&O	]	#&OX &*&*(,48@D<O<O ooc"	<O
 s#<O %<O #OOD1<O )/(=<O 
-<O|#O #O3 #O= #OJ'OC 'Oc 'Od 'OR$O $O# $ORp $OL$O $O3 $OSYS^S^_gSh $Or9   r,   c            '       N   \ rS rSrS\4S jrSSSSSS.S\R                  \   S\R                  \   S\R                  \   S	\R                  \	   S
\R                  \   S\R                  \   4S jjrSSS.S\R                  \   S
\R                  \   S\S\4S jjrSSS.S\R                  \   S
\R                  \   S\S\4S jjrS\S\4S jr\\\\\\\\\\\\S.S\S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\R                  \   S\4S  jjrS\SS4S! jrS\S\4S" jrS\S\4S# jrS\S\4S$ jrS\SS4S% jrS\S\4S& jr SSS'.S\S(\R                  \   S)\R                  \!   S\R                  \"   4S* jjr#S\S\R                  \$   S\R                  \"   4S+ jr%SSSSSS,.S\S(\R                  \   S)\R                  \!   S-\R                  \&   S.\R                  \&   S/\R                  \   S\'4S0 jjr(SSS'.S\S(\R                  \   S)\R                  \!   S\)4S1 jjr*S2\S\S\4S3 jr+\S4.S2\S\S5\R                  \RX                  \\R                  \-   4      S\"4S6 jjr.S2\S\SS4S7 jr/S\S8\R`                  S\RX                  \\4   4S9 jr1S\SS4S: jr2S\S\R                  \3   4S; jr4S\S\R                  \5   S\R                  \3   4S< jr6\S=.S(\S\S>\R                  \7   S\34S? jjr8S(\S\SS4S@ jr9S(\S\S\4SA jr:S(\S\S\4SB jr;SS\\\\\\\\\\\\\\SC.S\S\R                  \   S
\R                  \   SD\R                  \&   SE\R                  \7   SF\R                  \&   SG\R                  \!   SH\R                  \&   SI\R                  \7   SJ\R                  \<   SK\R                  \RX                  \\R                  \=   4      SL\R                  \&   SM\R                  \>   SN\R                  \!   SO\R                  \!   SP\R                  \!   SQ\SR\R                  \   S\?4&SS jjr@S\S\R                  \A   4ST jrBSU\S\S\A4SV jrCS\S\D4SW jrE\\\SX.S\SY\R                  \R                  \F      SZ\R                  \G   SR\R                  \   S\R                  4
S[ jjrISSSSSS\.S\S]\R                  \&   S-\R                  \&   S2\R                  \   S^\R                  \!   S_\R                  \!   S\R                  \J   4S` jjrKS\S\R                  \L   S\R                  \J   4Sa jrMS\S\R                  \L   S\R                  \J   4Sb jrNSSSSSS\.S\S]\R                  \&   S-\R                  \&   S2\R                  \   S^\R                  \!   S_\R                  \!   S\O4Sc jjrPSd\S\S\J4Se jrQSd\S\SS4Sf jrRSd\S\S\4Sg jrSSd\S\S\R                  \T   4Sh jrUSirVg)jAsyncPipelinesClienti  r.   c                    Xl         g r0   r1   r3   s     r5   r6   AsyncPipelinesClient.__init__  r8   r9   Nr:   r;   r<   r=   r>   r?   r@   c                  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        UUUUUS.5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)a  
Search for pipelines by various parameters.

Parameters:
    - project_id: typing.Optional[str].

    - project_name: typing.Optional[str].

    - pipeline_name: typing.Optional[str].

    - pipeline_type: typing.Optional[PipelineType].

    - organization_id: typing.Optional[str].
---
from llama_cloud import PipelineType
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.search_pipelines(
    pipeline_type=PipelineType.PLAYGROUND,
)
rB   rC   rD   r:   rE   rF   NrJ   rK   rL   rM   rP   r^   s           r5   ra   %AsyncPipelinesClient.search_pipelines  sO    B ..;;CCLL  D$8$8$E$E$G#H!JL^_(",$0%2%2'6 ((446 D 
 
	 )''-#-((X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN/
*  	Sy'<'<9>>RR	S+   BE;EBE;)E 9E;)E88E;rd   rR   c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        XS.5      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)rf   rg   rC   rD   rd   rE   rh   NrJ   rK   rL   rM   ri   rj   s         r5   rk   $AsyncPipelinesClient.create_pipeline  s:    " ..;;CCLL  D$8$8$E$E$G#H!JL^_(
)gh!'*((446 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   BE0EB	E0E .E0)E--E0c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3S5      [        XS.5      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)ro   rp   rC   rD   rd   rE   rh   NrJ   rK   rL   rM   ri   rj   s         r5   rq   $AsyncPipelinesClient.upsert_pipeline"  s:    $ ..;;CCLL  D$8$8$E$E$G#H!JL^_(
)gh!'*((446 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Sr}  rs   c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US
9e N! [         a    [!        UR                  UR"                  S
9ef = f7f)ru   rB   rC   rv   rE   rw   NrJ   rK   rL   rM   rx   ry   s       r5   rz   !AsyncPipelinesClient.get_pipelineF  s0     ..;;CCLL  D$8$8$E$E$G#H!JN_`k_lLmn((446	 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Ss+   A>E D/B	ED1 E1)EEr|   r}   r~   r   r   r   r   r   r   r   r   r   r   c                  #    0 nU[         La  X.S'   U[         La  X>S'   U[         La  XNS'   U[         La  X^S'   U[         La  XnS'   U[         La  X~S'   U[         La  XS'   U	[         La  XS'   U
[         La  XS	'   U[         La  XS
'   U[         La  XS'   U[         La  XS'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU 35      [        U5      U R                  R                  5       SS9I Sh  vN nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)r   r}   r~   r   r   r   r   r   r   r   r   r   r   rp   rC   rv   rE   r   NrJ   rK   rL   rM   r   r   s                    r5   r   -AsyncPipelinesClient.update_existing_pipeline]  s    ^ 244'+;'(4'+;'(t#'3^$$D04M01D $-[!&d26Q23$&*9&'!-1G-.!'X$&*9&'t#Vd*.A*+..;;CCLL  D$8$8$E$E$G#H!JN_`k_lLmn!(+((446 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Ss+   D&H(G)B	H3G H)HHc                 l  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S:  a   g  UR                  S	:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US
9e N! [         a    [        UR                  UR                   S
9ef = f7f)z
Delete a pipeline by ID.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.delete_pipeline(
    pipeline_id="string",
)
r   rC   rv   rE   rw   NrJ   rK   rL   rM   r   ry   s       r5   r   $AsyncPipelinesClient.delete_pipeline  s      ..;;CCLL  D$8$8$E$E$G#H!JN_`k_lLmn((446	 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Ss+   A>D4 DA D4"D 2D4)D11D4c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)z
Get the status of a pipeline by ID.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_status(
    pipeline_id="string",
)
rB   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   ry   s       r5   r   (AsyncPipelinesClient.get_pipeline_status  s4      ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llsLtu((446	 D 
 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	S+   A?ED0B	ED2 E2)EEc           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)r   rg   rC   rv   r   rE   rw   NrJ   rK   rL   rM   rx   ry   s       r5   r   "AsyncPipelinesClient.sync_pipeline  3     ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llqLrs((446	 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Sr  c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)r   rg   rC   rv   r   rE   rw   NrJ   rK   rL   rM   rx   ry   s       r5   r   )AsyncPipelinesClient.cancel_pipeline_sync  s6    
 ..;;CCLL  ''4467q9=N{m[g;h ((446 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Sr  c           	      n  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a   g  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e N! [         a    [        UR                  UR                   S9ef = f7f)z
Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.force_delete_pipeline(
    pipeline_id="string",
)
rg   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   ry   s       r5   r   *AsyncPipelinesClient.force_delete_pipeline$  s$     ..;;CCLL  ''4467q9=N{m[h;i ((446 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   A?D5DA D5#D	 3D5	)D22D5c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)r   rg   rC   rv   r   rE   rw   NrJ   rK   rL   rM   rx   ry   s       r5   r   "AsyncPipelinesClient.copy_pipelineD  r  r  r   r   r   c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        X#S.5      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)aS  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_files(
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rF   NrJ   rK   rL   rM   r   r   s         r5   r   (AsyncPipelinesClient.list_pipeline_files[  sL    4 ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llrLst(#1d ((446 D 
 
	 )''-#-((\)BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Srz  c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)a6  
Add files to a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[PipelineFileCreate].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.add_files_to_pipeline_api(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   r   rE   r   NrJ   rK   rL   rM   r   r   s        r5   r   .AsyncPipelinesClient.add_files_to_pipeline_api  sD    * ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llrLst!'*((446 D 
 
	 )''-#-((\)BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	S+   B	E9EBE9'E 7E9)E66E9r   r   r   r   c                  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e N! [          a    [#        UR                  UR$                  S9ef = f7f)a  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].

    - limit: typing.Optional[int].

    - offset: typing.Optional[int].

    - order_by: typing.Optional[str].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_files_2(
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rF   NrJ   rK   rL   rM   r   r   s	            r5   r   *AsyncPipelinesClient.list_pipeline_files_2  sS    F ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llsLtu(&4.D"$ ( ((446 D 
 
	 )''-#-(()KY^^M]^^  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN/
*  	Sy'<'<9>>RR	S+   BE.E B	E.E ,E.)E++E.c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        X#S.5      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e N! [          a    [#        UR                  UR$                  S9ef = f7f)a_  
Get files for a pipeline.

Parameters:
    - pipeline_id: str.

    - data_source_id: typing.Optional[str].

    - only_manually_uploaded: typing.Optional[bool].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_file_status_counts(
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rF   NrJ   rK   rL   rM   r   r   s         r5   r   4AsyncPipelinesClient.get_pipeline_file_status_counts  sG    4 ..;;CCLL  ''4467q9=N{m[o;p )#1d ((446 D 

 

	 )''-#-(()BINNDTUU  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN'

"  	Sy'<'<9>>RR	Ss+   BE*D<B	E*D> (E*>)E''E*r   c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)a+  
Get status of a file for a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_file_status(
    file_id="string",
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rw   NrJ   rK   rL   rM   r   r   s        r5   r   -AsyncPipelinesClient.get_pipeline_file_status	  s@    & ..;;CCLL  ''4467q9=N{m[bcjbkkr;s ((446 D 
 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   BE!D3B	E!D5 E!5)EE!r   r   c          
        #    0 nU[         La  X4S'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU SU 35      [        U5      U R                  R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)a  
Update a file for a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.

    - custom_metadata: typing.Optional[typing.Dict[str, typing.Optional[PipelineFileUpdateCustomMetadataValue]]].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.update_pipeline_file(
    file_id="string",
    pipeline_id="string",
)
r   rp   rC   rv   r   rE   r   NrJ   rK   rL   rM   r   r   s          r5   r   )AsyncPipelinesClient.update_pipeline_file>	  sZ    : 24$&*9&'..;;CCLL  ''4467q9=N{m[bcjbk;l "(+((446 D 
 
	 )''-#-((y~~7GHH  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	S+   BE9EB	E9'E 7E9)E66E9c           
      r  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a   g  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e N! [         a    [        UR                  UR                   S9ef = f7f)a!  
Delete a file from a pipeline.

Parameters:
    - file_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.delete_pipeline_file(
    file_id="string",
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   r   s        r5   r   )AsyncPipelinesClient.delete_pipeline_fileq	  s*    & ..;;CCLL  ''4467q9=N{m[bcjbk;l ((446 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   BD7D	A D7%D 5D7)D44D7r   c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        0 5      SU0U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  aC  O  O@[        R                  " [        R                  [        [        4   UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)r   rp   rC   rv   r   r   rE   r   NrJ   rK   rL   rM   r   r   s        r5   r   -AsyncPipelinesClient.import_pipeline_metadata	  sP     ..;;CCLL  D$8$8$E$E$G#H!JN_`k_lluLvw!"% +.((446 D 
 
	 )''-#-((S#X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Ss+   BFEB F0E  F)E??Fc           	      n  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a   g  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e N! [         a    [        UR                  UR                   S9ef = f7f)a  
Delete metadata for all files in a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.delete_pipeline_files_metadata(
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   ry   s       r5   r   3AsyncPipelinesClient.delete_pipeline_files_metadata	  s!      ..;;CCLL  D$8$8$E$E$G#H!JN_`k_lluLvw((446	 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Sr  c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)z
Get data sources for a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_data_sources(
    pipeline_id="string",
)
rB   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   ry   s       r5   r   /AsyncPipelinesClient.list_pipeline_data_sources	  s@      ..;;CCLL  ''4467q9=N{m[h;i ((446 D 
 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   A?E/EBE/E -E/)E,,E/c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)aF  
Add data sources to a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[PipelineDataSourceCreate].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.add_data_sources_to_pipeline(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   r   rE   r   NrJ   rK   rL   rM   r   r   s        r5   r   1AsyncPipelinesClient.add_data_sources_to_pipeline	  sH    * ..;;CCLL  ''4467q9=N{m[h;i "'*((446 D 
 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  r   r   c          
        #    0 nU[         La  X4S'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU SU 35      [        U5      U R                  R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)a~  
Update the configuration of a data source in a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.

    - sync_interval: typing.Optional[float].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.update_pipeline_data_source(
    data_source_id="string",
    pipeline_id="string",
)
r   rp   rC   rv   r   rE   r   NrJ   rK   rL   rM   r  r  s          r5   r  0AsyncPipelinesClient.update_pipeline_data_source
  sX    . 24$(5_%..;;CCLL  ''4467q9#K=~>NO "(+((446 D 	
 	
	 )''-#-(();Y^^=MNN  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN%	
   	Sy'<'<9>>RR	Sr  c           
      r  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a   g  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e N! [         a    [        UR                  UR                   S9ef = f7f)a=  
Delete a data source from a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.delete_pipeline_data_source(
    data_source_id="string",
    pipeline_id="string",
)
r   rC   rv   r   rE   rw   NrJ   rK   rL   rM   r   r  s        r5   r  0AsyncPipelinesClient.delete_pipeline_data_sourceI
  s(    & ..;;CCLL  ''4467q9#K=~>NO ((446 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)r
  rg   rC   rv   r   r   rE   rw   NrJ   rK   rL   rM   rx   r  s        r5   r  .AsyncPipelinesClient.sync_pipeline_data_sourceo
  s<     ..;;CCLL  ''4467q9#K=~>NeT ((446 D 
 
	 )''-#-((9>>3CDD  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)aK  
Get the status of a data source for a pipeline.

Parameters:
    - data_source_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_data_source_status(
    data_source_id="string",
    pipeline_id="string",
)
rB   rC   rv   r   r   rE   rw   NrJ   rK   rL   rM   r   r  s        r5   r  4AsyncPipelinesClient.get_pipeline_data_source_status
  s=    * ..;;CCLL  ''4467q9#K=~>NgV ((446 D 
 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  c          	      |  #    SU0nU[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U	[         La  U	US'   U
[         La  U
US'   U[         La  UUS	'   U[         La  UUS
'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U[         La  UUS'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU S35      [        X#S.5      [        U5      U R                  R                  5       SS9I Sh  vN nSUR                  s=::  a  S:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)a0  
Get retrieval results for a managed pipeline and a query

Parameters:
    - pipeline_id: str.

    - project_id: typing.Optional[str].

    - organization_id: typing.Optional[str].

    - dense_similarity_top_k: typing.Optional[int].

    - dense_similarity_cutoff: typing.Optional[float].

    - sparse_similarity_top_k: typing.Optional[int].

    - enable_reranking: typing.Optional[bool].

    - rerank_top_n: typing.Optional[int].

    - alpha: typing.Optional[float].

    - search_filters: typing.Optional[MetadataFilters].

    - search_filters_inference_schema: typing.Optional[typing.Dict[str, typing.Optional[RetrievalParamsSearchFiltersInferenceSchemaValue]]].

    - files_top_k: typing.Optional[int].

    - retrieval_mode: typing.Optional[RetrievalMode]. The retrieval mode for the query.

    - retrieve_image_nodes: typing.Optional[bool]. Whether to retrieve image nodes.

    - retrieve_page_screenshot_nodes: typing.Optional[bool]. Whether to retrieve page screenshot nodes.

    - retrieve_page_figure_nodes: typing.Optional[bool]. Whether to retrieve page figure nodes.

    - query: str. The query to retrieve against.

    - class_name: typing.Optional[str].
---
from llama_cloud import FilterCondition, MetadataFilters, RetrievalMode
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.run_search(
    pipeline_id="string",
    search_filters=MetadataFilters(
        filters=[],
        condition=FilterCondition.AND,
    ),
    retrieval_mode=RetrievalMode.CHUNKS,
    query="string",
)
r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  rg   rC   rv   r!  rd   rE   rh   NrJ   rK   rL   rM   r"  r#  s                         r5   r$  AsyncPipelinesClient.run_search
  sW    ` 3:51A!-1GH-."$.2IH./"$.2IH./4'+;H'(t#'3H^$ %HW%)7H%&*$6:YH67d"&1H]#%)7H%&t+/CH+,)59WH56%T15OH12T!%/H\"..;;CCLL  D$8$8$E$E$G#H!JN_`k_lluLvw(
)gh!(+((446 D 
 
	 )''-#-(()..:JKK  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Ss+   EH<H B	H<*H :H<)H99H<c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)z
Get jobs for a pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_jobs(
    pipeline_id="string",
)
rB   rC   rv   r'  rE   rw   NrJ   rK   rL   rM   r(  ry   s       r5   r)  'AsyncPipelinesClient.list_pipeline_jobs2  s=      ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llqLrs((446	 D 
 
	 )''-#-((5G)H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Sr  r+  c           
        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)a  
Get a job for a pipeline.

Parameters:
    - job_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_job(
    job_id="string",
    pipeline_id="string",
)
rB   rC   rv   r-  rE   rw   NrJ   rK   rL   rM   r.  r/  s        r5   r0  %AsyncPipelinesClient.get_pipeline_jobR  s=    & ..;;CCLL  ''4467q9=N{m[abhai;j ((446 D 
 
	 )''-#-(();Y^^=MNN  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	S+   BE D2B	E D4 E 4)EE c           	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)a  
Get a playground session for a user and pipeline.

Parameters:
    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_playground_session(
    pipeline_id="string",
)
rB   rC   rv   r4  rE   rw   NrJ   rK   rL   rM   r5  ry   s       r5   r6  +AsyncPipelinesClient.get_playground_sessionw  s7      ..;;CCLL  ''4467q9=N{m[n;o ((446 D 
 
	 )''-#-(():INN<LMM  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Sr  r8  r9  r   c          	      :  #    0 nU[         La  X%S'   U[         La  X5S'   U[         La  XES'   U R                  R                  R                  S[        R
                  R                  U R                  R                  5        S3SU S35      [        U5      U R                  R                  5       SS	9I S
h  vN nSUR                  s=::  a  S:  a6  O  O3[        R                  " [        R                  UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)a  
Make a retrieval query + chat completion for a managed pipeline.

Parameters:
    - pipeline_id: str.

    - messages: typing.Optional[typing.List[InputMessage]].

    - data: typing.Optional[ChatData].

    - class_name: typing.Optional[str].
---
from llama_cloud import (
    ChatData,
    FilterCondition,
    LlmParameters,
    MetadataFilters,
    PresetRetrievalParams,
    RetrievalMode,
    SupportedLlmModelNames,
)
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.chat(
    pipeline_id="string",
    data=ChatData(
        retrieval_parameters=PresetRetrievalParams(
            search_filters=MetadataFilters(
                filters=[],
                condition=FilterCondition.AND,
            ),
            retrieval_mode=RetrievalMode.CHUNKS,
        ),
        llm_parameters=LlmParameters(
            model_name=SupportedLlmModelNames.GPT_4_O,
        ),
    ),
)
r9  r   r  rg   rC   rv   r;  rE   r   NrJ   rK   rL   rM   r<  r>  s           r5   r?  AsyncPipelinesClient.chat  su    d 244#+Z t#VT!%/\"..;;CCLL  D$8$8$E$E$G#H!JN_`k_llqLrs!(+((446 D 
 
	 )''-#-((Y^^5EFF  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN
  	Sy'<'<9>>RR	Ss+   B2F4E-5BF	E/ F/)FFrA  rB  rC  rD  c                  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)a  
Return a list of documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - skip: typing.Optional[int].

    - limit: typing.Optional[int].

    - file_id: typing.Optional[str].

    - only_direct_upload: typing.Optional[bool].

    - only_api_data_source_documents: typing.Optional[bool].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_documents(
    pipeline_id="string",
)
rB   rC   rv   rF  rA  rE   rF   NrJ   rK   rL   rM   rG  rH  s	            r5   rI  ,AsyncPipelinesClient.list_pipeline_documents  s^    F ..;;CCLL  ''4467q9=N{m[e;f ) "&*<6T ((446 D 
 
	" )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN3
.  	Sy'<'<9>>RR	Ss+   BE?EBE?-E =E?)E<<E?c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)aK  
Batch create documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[CloudDocumentCreate].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.create_batch_pipeline_documents(
    pipeline_id="string",
    request=[],
)
rg   rC   rv   rF  rE   r   NrJ   rK   rL   rM   rL  r   s        r5   rM  4AsyncPipelinesClient.create_batch_pipeline_documents!  sG    * ..;;CCLL  ''4467q9=N{m[e;f "'*((446 D 
 
	 )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  c          	        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        U5      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S
:X  a2  [!        [        R                  " ["        UR                  5       5      5      e UR                  5       n['        UR                  US9e N! [$         a    ['        UR                  UR(                  S9ef = f7f)aV  
Batch create or update a document for a pipeline.

Parameters:
    - pipeline_id: str.

    - request: typing.List[CloudDocumentCreate].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.upsert_batch_pipeline_documents(
    pipeline_id="string",
    request=[],
)
rp   rC   rv   rF  rE   r   NrJ   rK   rL   rM   rL  r   s        r5   rP  4AsyncPipelinesClient.upsert_batch_pipeline_documentsI  sG    * ..;;CCLL  ''4467q9=N{m[e;f "'*((446 D 
 
	 )''-#-((])CY^^EUVV  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  c                  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU S35      [        UUUUUS.5      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[#        UR                  US9e N! [          a    [#        UR                  UR$                  S9ef = f7f)a  
Return a list of documents for a pipeline.

Parameters:
    - pipeline_id: str.

    - skip: typing.Optional[int].

    - limit: typing.Optional[int].

    - file_id: typing.Optional[str].

    - only_direct_upload: typing.Optional[bool].

    - only_api_data_source_documents: typing.Optional[bool].
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.paginated_list_pipeline_documents(
    pipeline_id="string",
)
rB   rC   rv   rS  rA  rE   rF   NrJ   rK   rL   rM   rT  rH  s	            r5   rU  6AsyncPipelinesClient.paginated_list_pipeline_documentsq  sV    F ..;;CCLL  ''4467q9=N{m[o;p ) "&*<6T ((446 D 
 
	" )''-#-(()LinnN^__  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN3
.  	Sy'<'<9>>RR	Sr  rW  c           
        #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)a4  
Return a single document for a pipeline.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_document(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   rY  rE   rw   NrJ   rK   rL   rM   rZ  r[  s        r5   r\  *AsyncPipelinesClient.get_pipeline_document  s<    & ..;;CCLL  ''4467q9=N{m[fgrfs;t ((446 D 
 
	 )''-#-((	8HII  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Sr  c           
      r  #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU 35      U R                   R                  5       SS9I Sh  vN nSUR                  s=::  a  S	:  a   g  UR                  S
:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[        UR                  US9e N! [         a    [        UR                  UR                   S9ef = f7f)a  
Delete a document from a pipeline.
Initiates an async job that will:

1. Delete vectors from the vector store
2. Delete the document from MongoDB after vectors are successfully deleted

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.delete_pipeline_document(
    document_id="string",
    pipeline_id="string",
)
r   rC   rv   rY  rE   rw   NrJ   rK   rL   rM   r   r[  s        r5   r_  -AsyncPipelinesClient.delete_pipeline_document  s*    . ..;;CCLL  ''4467q9=N{m[fgrfs;t ((446 D 
 
	 )''-#- .  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN!
  	Sy'<'<9>>RR	Sr  c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a,  O  O)[        R                  " [        UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [        UR                  5       5      5      e UR                  5       n[!        UR                  US9e N! [         a    [!        UR                  UR"                  S9ef = f7f)a;  
Return a single document for a pipeline.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.get_pipeline_document_status(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   rY  r   rE   rw   NrJ   rK   rL   rM   r   r[  s        r5   rb  1AsyncPipelinesClient.get_pipeline_document_status  s<    & ..;;CCLL  ''4467q9#K=K=P ((446 D 
 
	 )''-#-(()GIYZZ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Sr  c                   #    U R                   R                  R                  S[        R                  R                  U R                   R                  5        S3SU SU S35      U R                   R                  5       SS9I Sh  vN nS	UR                  s=::  a  S
:  a=  O  O:[        R                  " [        R                  [           UR                  5       5      $ UR                  S:X  a2  [        [        R                  " [         UR                  5       5      5      e UR                  5       n[%        UR                  US9e N! ["         a    [%        UR                  UR&                  S9ef = f7f)aD  
Return a list of chunks for a pipeline document.

Parameters:
    - document_id: str.

    - pipeline_id: str.
---
from llama_cloud.client import AsyncLlamaCloud

client = AsyncLlamaCloud(
    token="YOUR_TOKEN",
)
await client.pipelines.list_pipeline_document_chunks(
    document_id="string",
    pipeline_id="string",
)
rB   rC   rv   rY  re  rE   rw   NrJ   rK   rL   rM   rf  r[  s        r5   rg  2AsyncPipelinesClient.list_pipeline_document_chunks#  sD    & ..;;CCLL  ''4467q9#K=K=P ((446 D 
 
	 )''-#-((X)>	@PQQ  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN#
  	Sy'<'<9>>RR	Ss+   BE2EBE2 E 0E2)E//E2r1   )Wri  rj  rk  rl  r   r6   rZ   rm  r   r    r[   r   ra   r   rk   rq   rz   r   r(   r)   r   r"   r   r   r   r   r   r   r   r   r   r   r   rn  r   r   r   r   ro  r   r   r   r   r   r   r'   r   r   rp  r   r   r   r   r   r   rq  r  r  r  r  r   r*   r#   r$   r$  r   r)  r0  r!   r6  r   r   r=  r?  r   rI  r   rM  rP  r   rU  r\  r_  rb  r%   rg  rr  rs  r9   r5   ru  ru    s   .*< . ,0-1.27;048O OOC(8O ooc*	8O
 s+8O |48O  -8O 
X	8Oz ,004	!O OOC(!O  -	!O
  !O 
!OL ,004	"O OOC("O  -	"O
  "O 
"OHOc Oh O6 LPKO-1:>59NR@DHL'+CG%)48WOWO !//*GH	WO
 !//*GHWO ooc*WO $*??3#7WO ??>2WO &,__5J%KWO  )<=WO !'0D EWO $WO  )?@WO ooc"WO $__S1WO  
!WOrO O O@OS O=[ O@Os Ox O.Oc Oh O.Os Ot O@Os Ox O6 048<+O+O ,	+O
 !' 5+O 
\	"+OZ$O$O,2KK8J,K$O	\	"$OT 048<&*'+)-:O:O ,	:O
 !' 5:O s#:O $:O //#&:O 
,:O@ 048<-O-O ,	-O
 !' 5-O 
#-O^#Oc #O #OPn #OX 1O1O 1O
  KKV__-RSST
1O 
1Of#O# #OC #OD #OJO# Ovyy O]c]h]hilnqiq]r O6O O O@ OC  OFKKPbDc  OD&O&O,2KK8P,Q&O	'	(&OR ae,O!,O03,OGMW\G],O	,O\$O $ORU $OZ^ $OLOc OPS OX` O8&O!&O03&O	'&OX ,0047;:>8<26-1(,;? ,09=6:@D<@+/-}O}O OOC(	}O
  -}O !' 4}O "(!7}O "(!5}O !//$/}O ooc*}O u%}O 8}O *0KKV__-]^^_*
}O  __S)!}O" 6#}O$ %ood3%}O& )/(='}O( %+OOD$9)}O* +}O, OOC(-}O. 
/}O~OC OFKKHZ<[ O@#OS #Os #OGY #OJ O  O@Q  OL @D*.+/HOHO //&++l";<	HO
 ooh'HO OOC(HO 
HO\ &*&*(,48@D<O<O ooc"	<O
 s#<O %<O #OOD1<O )/(=<O 
]	#<O|&O&O,2KK8K,L&O	]	#&OP&O&O,2KK8K,L&O	]	#&OX &*&*(,48@D<O<O ooc"	<O
 s#<O %<O #OOD1<O )/(=<O 
-<O|#Os #O #OQ^ #OJ'O# 'OC 'OTX 'OR$Oc $OPS $OXv $OL$Os $OQT $OY_YdYdemYn $Or9   ru  )YrZ   urllib.parserS   json.decoderr   core.api_errorr   core.client_wrapperr   r   core.jsonable_encoderr   core.remove_none_from_dictr	   !errors.unprocessable_entity_errorr
   types.chat_datar   types.cloud_documentr   types.cloud_document_creater   types.data_sink_creater   types.eval_execution_paramsr   #types.file_count_by_status_responser   types.http_validation_errorr   types.input_messager   types.llama_parse_parametersr   'types.managed_ingestion_status_responser   types.metadata_filtersr   -types.paginated_list_cloud_documents_responser   ,types.paginated_list_pipeline_files_responser   types.pipeliner   types.pipeline_creater   types.pipeline_data_sourcer   !types.pipeline_data_source_creater   types.pipeline_deploymentr   types.pipeline_filer   types.pipeline_file_creater   types.pipeline_metadata_configr   types.pipeline_typer    types.playground_sessionr!   types.preset_retrieval_paramsr"   types.retrieval_moder#   types.retrieve_resultsr$   types.text_noder%   0types.pipeline_file_update_custom_metadata_valuer'   &types.pipeline_update_embedding_configr(   &types.pipeline_update_transform_configr)   <types.retrieval_params_search_filters_inference_schema_valuer*   rX   __version__
startswithImportErrorpydantic.v1v1castr=  r   r,   ru  rs  r9   r5   <module>r     s      ( & H 5 ? I ' 1 > 4 > L > / @ U 5 ` ^ & 3 < I ; / < D / 9 B 1 5 ' c Q Q&&t,,"
 {{6::s#DO DON4FO FO]4  s   *,E 
EE