
    Jiy                        d dl Z d dlZd dlmZ ddlmZ ddlmZm	Z	 ddl
mZ ddlmZ ddlmZ dd	lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ 	 d dlZej>                  jA                  d      re!d dl"m#Z  e jH                  e jJ                  d      Z& G d d      Z' G d d      Z(y# e!$ r d dlZY =w xY w)    N)JSONDecodeError   )ApiError)AsyncClientWrapperSyncClientWrapper)jsonable_encoder)remove_none_from_dict)UnprocessableEntityError)FileCountByStatusResponse)HttpValidationError)ManagedIngestionStatusResponse)"PaginatedListPipelineFilesResponse)PipelineFile)PipelineFileCreate   )%PipelineFileUpdateCustomMetadataValuez1..c                      e Zd ZdefdZddddedej                  e   dej                  e   dej                  e
   fd	Zded
ej                  e   dej                  e
   fdZddddedej                  e   dej                  e   defdZeddededej                  ej"                  eej                  e   f      de
fdZdededdfdZdededefdZddddddddedej                  e   dej                  e   dej                  e   dej                  e   dej                  e   dej                  e   defdZdedej4                  dej"                  eef   fdZdeddfdZy)PipelineFilesClientclient_wrapperc                    || _         y N_client_wrapperselfr   s     }/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/llama_cloud/resources/pipeline_files/client.py__init__zPipelineFilesClient.__init__!   
    -    Ndata_source_idonly_manually_uploadedpipeline_idr!   r"   returnc          	         | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||d      | j                   j                         d      }d|j                  cxk  rd	k  r<n n9t        j                  t        j                  t           |j                               S |j                  d
k(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |      # t$        $ r" t'        |j                  |j(                        w xY w)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 LlamaCloud

        client = LlamaCloud(
            token="YOUR_TOKEN",
        )
        client.pipeline_files.list_pipeline_files(
            pipeline_id="string",
        )
        GET/api/v1/pipelines//filesr    <   paramsheaderstimeout   ,    status_codebodyr   httpx_clientrequesturllibparseurljoinget_base_urlr	   get_headersr3   pydanticparse_obj_astypingListr   jsonr
   r   r   r   textr   r#   r!   r"   	_response_response_jsons         r   list_pipeline_filesz'PipelineFilesClient.list_pipeline_files$   sB   4 ((55==LL  D$8$8$E$E$G#H!JN_`k_llrLst(#1Mc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   E +E0r7   c          	         | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        |      | j                   j                         d      }d|j                  cxk  rdk  r<n n9t        j                  t        j                  t           |j                               S |j                  d	k(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |
      # t$        $ r" t'        |j                  |j(                  
      w xY w)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.pipeline_files.add_files_to_pipeline_api(
            pipeline_id="string",
            request=[],
        )
        PUTr'   r(   r)   r*   rA   r-   r.   r/   r0   r1   r2   r   r6   r7   r8   r9   r:   r;   r   r<   r3   r=   r>   r?   r@   r   rA   r
   r   r   r   rB   r   r#   r7   rD   rE   s        r   add_files_to_pipeline_apiz-PipelineFilesClient.add_files_to_pipeline_apiQ   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-c          	         | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||d      | j                   j                         d      }d|j                  cxk  rd	k  r+n n(t        j                  t        |j                               S |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t#        |j                  |      # t         $ r" t#        |j                  |j$                        w xY w)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 LlamaCloud

        client = LlamaCloud(
            token="YOUR_TOKEN",
        )
        client.pipeline_files.get_pipeline_file_status_counts(
            pipeline_id="string",
        )
        r&   r'   r(   /files/status-countsr    r*   r+   r/   r0   r1   r2   r   r6   r7   r8   r9   r:   r;   r	   r<   r3   r=   r>   r   rA   r
   r   r   r   rB   rC   s         r   get_pipeline_file_status_countsz3PipelineFilesClient.get_pipeline_file_status_countsw   s=   4 ((55==LL  ''4467q9=N{m[o;p )#1Mc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   D4 4+Ecustom_metadatafile_idrS   c          
         i }|t         ur||d<   | j                  j                  j                  dt        j
                  j                  | j                  j                          dd| d|       t        |      | j                  j                         d      }d|j                  cxk  rd	k  r+n n(t        j                  t        |j                               S |j                  d
k(  r1t        t        j                  t         |j                                     	 |j                         }t%        |j                  |      # t"        $ r" t%        |j                  |j&                        w xY w)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.pipeline_files.update_pipeline_file(
            file_id="string",
            pipeline_id="string",
        )
        rS   rH   r'   r(   /files/r*   rI   r/   r0   r1   r2   OMITr   r6   r7   r8   r9   r:   r;   r   r<   r3   r=   r>   r   rA   r
   r   r   r   rB   r   rT   r#   rS   _requestrD   rE   s          r   update_pipeline_filez(PipelineFilesClient.update_pipeline_file   sO   : 24$&*9H&'((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rM   c           
      \   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d|       | j                   j                         d      }d|j                  cxk  rdk  ry	 |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t        |j                  |      # t        $ r" t        |j                  |j                         w xY w)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.pipeline_files.delete_pipeline_file(
            file_id="string",
            pipeline_id="string",
        )
        DELETEr'   r(   rV   r*   r-   r.   r/   r0   Nr1   r2   r   r6   r7   r8   r9   r:   r;   r<   r3   r
   r=   r>   r   rA   r   r   rB   r   rT   r#   rD   rE   s        r   delete_pipeline_filez(PipelineFilesClient.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s   D   +D+c                    | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d| d      | j                   j                         d      }d|j                  cxk  rd	k  r+n n(t        j                  t        |j                               S |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t!        |j                  |      # t        $ r" t!        |j                  |j"                        w xY w)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.pipeline_files.get_pipeline_file_status(
            file_id="string",
            pipeline_id="string",
        )
        r&   r'   r(   rV   /statusr*   r^   r/   r0   r1   r2   r   r6   r7   r8   r9   r:   r;   r<   r3   r=   r>   r   rA   r
   r   r   r   rB   r`   s        r   get_pipeline_file_statusz,PipelineFilesClient.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s   D* *+Er!   r"   file_name_containslimitoffsetorder_byrg   rh   ri   rj   c                   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||||||d      | j                   j                         d      }d|j                  cxk  rd	k  r+n n(t        j                  t        |j                               S |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }	t#        |j                  |	      # t         $ r" t#        |j                  |j$                        w xY w)a  
        Get files for a pipeline.

        Args:
        pipeline_id: ID of the pipeline
        data_source_id: Optional filter by data source ID
        only_manually_uploaded: Filter for only manually uploaded files
        file_name_contains: Optional filter by file name (substring match)
        limit: Limit number of results
        offset: Offset for pagination
        order_by: Field to order by

        Parameters:
            - pipeline_id: str.

            - data_source_id: typing.Optional[str].

            - only_manually_uploaded: typing.Optional[bool].

            - file_name_contains: typing.Optional[str].

            - 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.pipeline_files.list_pipeline_files_2(
            pipeline_id="string",
        )
        r&   r'   r(   /files2rf   r*   r+   r/   r0   r1   r2   r   r6   r7   r8   r9   r:   r;   r	   r<   r3   r=   r>   r   rA   r
   r   r   r   rB   
r   r#   r!   r"   rg   rh   ri   rj   rD   rE   s
             r   list_pipeline_files_2z)PipelineFilesClient.list_pipeline_files_2#  sI   ^ ((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s   D8 8+E#upload_filec          	         | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        i       d|i| j                   j                         d      }d|j                  cxk  rd	k  rBn n?t        j                  t        j                  t        t        f   |j                               S |j                  d
k(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |      # t$        $ r" t'        |j                  |j(                        w xY w)
        Import metadata for a pipeline.

        Parameters:
            - pipeline_id: str.

            - upload_file: typing.IO.
        rH   r'   r(   	/metadatarp   r*   datafilesr-   r.   r/   r0   r1   r2   r   r6   r7   r8   r9   r:   r;   r   r<   r3   r=   r>   r?   DictstrrA   r
   r   r   r   rB   r   r#   rp   rD   rE   s        r   import_pipeline_metadataz,PipelineFilesClient.import_pipeline_metadatal  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 +E6c           	      X   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      | j                   j                         d      }d|j                  cxk  rdk  ry	 |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t        |j                  |      # t        $ r" t        |j                  |j                         w xY w)ac  
        Delete metadata for all files in a pipeline.

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

        client = LlamaCloud(
            token="YOUR_TOKEN",
        )
        client.pipeline_files.delete_pipeline_files_metadata(
            pipeline_id="string",
        )
        r]   r'   r(   rs   r*   r^   r/   r0   Nr1   r2   r_   r   r#   rD   rE   s       r   delete_pipeline_files_metadataz2PipelineFilesClient.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s   C> >+D))__name__
__module____qualname__r   r   ry   r?   Optionalboolr@   r   rF   r   rL   r   rQ   rX   rx   r   r[   ra   r   re   intr   ro   IOr{   r~    r   r   r   r       sw   .*; . 048<+O+O ,	+O
 !' 5+O 
\	"+OZ$O$O,2KK8J,K$O	\	"$OT 048<-O-O ,	-O
 !' 5-O 
#-Ol 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 #O# #OJh #OR 048<37&*'+)-GOGO ,	GO
 !' 5GO #OOC0GO s#GO $GO //#&GO 
,GOROC O OW]WbWbcfhkckWl O6O# O$ Or   r   c                      e Zd ZdefdZddddedej                  e   dej                  e   dej                  e
   fd	Zded
ej                  e   dej                  e
   fdZddddedej                  e   dej                  e   defdZeddededej                  ej"                  eej                  e   f      de
fdZdededdfdZdededefdZddddddddedej                  e   dej                  e   dej                  e   dej                  e   dej                  e   dej                  e   defdZdedej4                  dej"                  eef   fdZdeddfdZy)AsyncPipelineFilesClientr   c                    || _         y r   r   r   s     r   r   z!AsyncPipelineFilesClient.__init__  r   r   Nr    r#   r!   r"   r$   c          	        K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||d      | j                   j                         d       d{   }d	|j                  cxk  rd
k  r<n n9t        j                  t        j                  t           |j                               S |j                  dk(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |      7 # t$        $ r" t'        |j                  |j(                        w xY ww)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.pipeline_files.list_pipeline_files(
            pipeline_id="string",
        )
        r&   r'   r(   r)   r    r*   r+   Nr/   r0   r1   r2   r5   rC   s         r   rF   z,AsyncPipelineFilesClient.list_pipeline_files  sP    4 ..;;CCLL  D$8$8$E$E$G#H!JN_`k_llrLst(#1Mc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?EBE?(E 8E?+E<<E?r7   c          	        K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        |      | j                   j                         d       d{   }d|j                  cxk  rd	k  r<n n9t        j                  t        j                  t           |j                               S |j                  d
k(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |      7 # t$        $ r" t'        |j                  |j(                        w xY ww)a  
        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.pipeline_files.add_files_to_pipeline_api(
            pipeline_id="string",
            request=[],
        )
        rH   r'   r(   r)   r*   rI   Nr/   r0   r1   r2   rJ   rK   s        r   rL   z2AsyncPipelineFilesClient.add_files_to_pipeline_api  sE    * ..;;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s+   BE<EBE<%E 5E<+E99E<c          	        K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||d      | j                   j                         d       d{   }d	|j                  cxk  rd
k  r+n n(t        j                  t        |j                               S |j                  dk(  r1t        t        j                  t        |j                                     	 |j                         }t#        |j                  |      7 # t         $ r" t#        |j                  |j$                        w xY ww)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.pipeline_files.get_pipeline_file_status_counts(
            pipeline_id="string",
        )
        r&   r'   r(   rO   r    r*   r+   Nr/   r0   r1   r2   rP   rC   s         r   rQ   z8AsyncPipelineFilesClient.get_pipeline_file_status_counts  sK    4 ..;;CCLL  ''4467q9=N{m[o;p )#1Mc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.E  'E. +E++E.rR   rT   rS   c          
        K   i }|t         ur||d<   | j                  j                  j                  dt        j
                  j                  | j                  j                          dd| d|       t        |      | j                  j                         d       d{   }d	|j                  cxk  rd
k  r+n n(t        j                  t        |j                               S |j                  dk(  r1t        t        j                  t         |j                                     	 |j                         }t%        |j                  |      7 # t"        $ r" t%        |j                  |j&                        w xY ww)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.pipeline_files.update_pipeline_file(
            file_id="string",
            pipeline_id="string",
        )
        rS   rH   r'   r(   rV   r*   rI   Nr/   r0   r1   r2   rW   rY   s          r   r[   z-AsyncPipelineFilesClient.update_pipeline_file.  s]    : 24$&*9H&'..;;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s+   BE<E BE<%E 5E<+E99E<c           
      x  K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d|       | j                   j                         d       d{   }d|j                  cxk  rd	k  ry |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t        |j                  |      7 # t        $ r" t        |j                  |j                         w xY ww)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.pipeline_files.delete_pipeline_file(
            file_id="string",
            pipeline_id="string",
        )
        r]   r'   r(   rV   r*   r^   Nr/   r0   r1   r2   r_   r`   s        r   ra   z-AsyncPipelineFilesClient.delete_pipeline_filea  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s+   BD:D
AD:#D 3D:+D77D:c                   K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d| d      | j                   j                         d       d{   }d	|j                  cxk  rd
k  r+n n(t        j                  t        |j                               S |j                  dk(  r1t        t        j                  t        |j                                     	 |j                         }t!        |j                  |      7 # t        $ r" t!        |j                  |j"                        w xY ww)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.pipeline_files.get_pipeline_file_status(
            file_id="string",
            pipeline_id="string",
        )
        r&   r'   r(   rV   rc   r*   r^   Nr/   r0   r1   r2   rd   r`   s        r   re   z1AsyncPipelineFilesClient.get_pipeline_file_status  sA    & ..;;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s+   BE$D4BE$D6 E$6+E!!E$rf   rg   rh   ri   rj   c                  K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        ||||||d      | j                   j                         d       d{   }d	|j                  cxk  rd
k  r+n n(t        j                  t        |j                               S |j                  dk(  r1t        t        j                  t        |j                                     	 |j                         }	t#        |j                  |	      7 # t         $ r" t#        |j                  |j$                        w xY ww)a   
        Get files for a pipeline.

        Args:
        pipeline_id: ID of the pipeline
        data_source_id: Optional filter by data source ID
        only_manually_uploaded: Filter for only manually uploaded files
        file_name_contains: Optional filter by file name (substring match)
        limit: Limit number of results
        offset: Offset for pagination
        order_by: Field to order by

        Parameters:
            - pipeline_id: str.

            - data_source_id: typing.Optional[str].

            - only_manually_uploaded: typing.Optional[bool].

            - file_name_contains: typing.Optional[str].

            - 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.pipeline_files.list_pipeline_files_2(
            pipeline_id="string",
        )
        r&   r'   r(   rl   rf   r*   r+   Nr/   r0   r1   r2   rm   rn   s
             r   ro   z.AsyncPipelineFilesClient.list_pipeline_files_2  sW    ^ ..;;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N1
,  	Sy'<'<9>>RR	Ss+   BE2EBE2E +E2+E//E2rp   c          	        K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      t        i       d|i| j                   j                         d       d{   }d	|j                  cxk  rd
k  rBn n?t        j                  t        j                  t        t        f   |j                               S |j                  dk(  r1t!        t        j                  t"        |j                                     	 |j                         }t'        |j                  |      7 # t$        $ r" t'        |j                  |j(                        w xY ww)rr   rH   r'   r(   rs   rp   r*   rt   Nr/   r0   r1   r2   rw   rz   s        r   r{   z1AsyncPipelineFilesClient.import_pipeline_metadata  sQ     ..;;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.E >F+FFc           	      t  K   | j                   j                  j                  dt        j                  j                  | j                   j                          dd| d      | j                   j                         d       d{   }d|j                  cxk  rd	k  ry |j                  d
k(  r1t        t        j                  t        |j                                     	 |j                         }t        |j                  |      7 # t        $ r" t        |j                  |j                         w xY ww)as  
        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.pipeline_files.delete_pipeline_files_metadata(
            pipeline_id="string",
        )
        r]   r'   r(   rs   r*   r^   Nr/   r0   r1   r2   r_   r}   s       r   r~   z7AsyncPipelineFilesClient.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s+   BD8DAD8!D
 1D8
+D55D8)r   r   r   r   r   ry   r?   r   r   r@   r   rF   r   rL   r   rQ   rX   rx   r   r[   ra   r   re   r   r   ro   r   r{   r~   r   r   r   r   r     sw   .*< . 048<+O+O ,	+O
 !' 5+O 
\	"+OZ$O$O,2KK8J,K$O	\	"$OT 048<-O-O ,	-O
 !' 5-O 
#-Ol 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c #O #OPn #OR 048<37&*'+)-GOGO ,	GO
 !' 5GO #OOC0GO s#GO $GO //#&GO 
,GORO# Ovyy O]c]h]hilnqiq]r O6O O Or   r   ))r?   urllib.parser8   json.decoderr   core.api_errorr   core.client_wrapperr   r   core.jsonable_encoderr   core.remove_none_from_dictr	   !errors.unprocessable_entity_errorr
   #types.file_count_by_status_responser   types.http_validation_errorr   'types.managed_ingestion_status_responser   ,types.paginated_list_pipeline_files_responser   types.pipeline_filer   types.pipeline_file_creater   0types.pipeline_file_update_custom_metadata_valuer   r=   __version__
startswithImportErrorpydantic.v1v1castAnyrX   r   r   r   r   r   <module>r      s      ( & H 5 ? I L > U ^ / < c&&t,"
 v{{6::s#EO EOPEO EO_  s   'B3 3	B?>B?