
    Ji                        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Zej&                  j)                  d
      red dlm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)remove_none_from_dict)UnprocessableEntityError)HttpValidationError)PaginatedJobsHistoryWithMetricsz1.c                       e Zd ZdefdZddddddd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
y)
JobsClientclient_wrapperc                    || _         y N_client_wrapperselfr   s     s/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/llama_cloud/resources/jobs/client.py__init__zJobsClient.__init__   
    -    Njob_namelimitoffsetsort
project_idorganization_idr   r   r   r   r   r   returnc                   | j                   j                  j                  dt        j                  j                  | j                   j                          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 jobs for a project.

        Note:
        The include_usage_metrics parameter is deprecated and will be removed in a future version.
        We've moved to usage v2 and this parameter will no longer return meaningful data.

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

            - limit: typing.Optional[int].

            - offset: typing.Optional[int].

            - sort: typing.Optional[str].

            - project_id: typing.Optional[str].

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

        client = LlamaCloud(
            token="YOUR_TOKEN",
        )
        client.jobs.get_jobs()
        GET/api/v1/jobsr   <   paramsheaderstimeout   ,    status_codebodyr   httpx_clientrequesturllibparseurljoinget_base_urlr   get_headersr.   pydanticparse_obj_asr   jsonr	   r
   r   r   text	r   r   r   r   r   r   r   	_response_response_jsons	            r   get_jobszJobsClient.get_jobs   s<   J ((55==LL  D$8$8$E$E$G#H!JMZ( ("$ ",'6	 ((446 > 
	  )''-#-(()H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN  	Sy'<'<9>>RR	Ss   D4 4+E)__name__
__module____qualname__r   r   typingOptionalstrintr   r?    r   r   r   r      s    .*; . *.&*'+%)+/04=O //#&=O s#	=O
 $=O ooc"=O OOC(=O  -=O 
)=Or   r   c                       e Zd ZdefdZddddddd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
y)AsyncJobsClientr   c                    || _         y r   r   r   s     r   r   zAsyncJobsClient.__init__\   r   r   Nr   r   r   r   r   r   r   r    c                  K   | j                   j                  j                  dt        j                  j                  | j                   j                          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 jobs for a project.

        Note:
        The include_usage_metrics parameter is deprecated and will be removed in a future version.
        We've moved to usage v2 and this parameter will no longer return meaningful data.

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

            - limit: typing.Optional[int].

            - offset: typing.Optional[int].

            - sort: typing.Optional[str].

            - project_id: typing.Optional[str].

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

        client = AsyncLlamaCloud(
            token="YOUR_TOKEN",
        )
        await client.jobs.get_jobs()
        r"   r#   r$   r   r%   r&   Nr*   r+   r,   r-   r0   r<   s	            r   r?   zAsyncJobsClient.get_jobs_   sJ    J ..;;CCLL  D$8$8$E$E$G#H!JMZ( ("$ ",'6	 ((446 D 
 
	  )''-#-(()H)..JZ[[  C'*8+@+@ATV_VdVdVf+ghh	S&^^-N 9#8#8~NN1
,  	Sy'<'<9>>RR	Ss+   BE.D>BE.E  'E. +E++E.)r@   rA   rB   r   r   rC   rD   rE   rF   r   r?   rG   r   r   rI   rI   [   s    .*< . *.&*'+%)+/04=O //#&=O s#	=O
 $=O ooc"=O OOC(=O  -=O 
)=Or   rI   )rC   urllib.parser3   json.decoderr   core.api_errorr   core.client_wrapperr   r   core.remove_none_from_dictr   !errors.unprocessable_entity_errorr	   types.http_validation_errorr
   )types.paginated_jobs_history_with_metricsr   r8   __version__
startswithImportErrorpydantic.v1v1r   rI   rG   r   r   <module>rY      sy      ( & H ? I > X&&t,"
AO AOHAO AOQ  s   'A2 2	A>=A>