o
    |!g
                     @   s   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 zd dlZejd
rAed dlmZ W n eyU   d dlZY nw G dd dZG dd dZdS )    N)JSONDecodeError   )ApiError)AsyncClientWrapperSyncClientWrapper)remove_none_from_dict)UnprocessableEntityError)HttpValidationError)PaginatedJobsHistoryWithMetricsz1.c                   @   t   e Zd Zdefd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dZdS )
JobsClientclient_wrapperc                C   
   || _ d S N_client_wrapperselfr    r   c/mnt/skqttb/ctump_chatbot/chatbot/lib/python3.10/site-packages/llama_cloud/resources/jobs/client.py__init__      
zJobsClient.__init__Njob_namelimitoffsetinclude_usage_metrics
project_idorganization_idr   r   r   r   r   r   returnc          	      C   s   | j jjdtj| j   ddt||||||d| j  dd}d|j	  kr.dk r8n nt
t| S |j	d	krGtt
t| z| }W n ty\   t|j	|jd
w t|j	|d
)a  
        Get jobs for a project.

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

            - limit: typing.Optional[int].

            - offset: typing.Optional[int].

            - include_usage_metrics: typing.Optional[bool].

            - 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_api_v_1_jobs_get()
        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_jsonr   r   r   get_jobs_api_v_1_jobs_get   s2   !

z$JobsClient.get_jobs_api_v_1_jobs_get)__name__
__module____qualname__r   r   typingOptionalstrintboolr
   r=   r   r   r   r   r      .    	r   c                   @   r   )AsyncJobsClientr   c                C   r   r   r   r   r   r   r   r   X   r   zAsyncJobsClient.__init__Nr   r   r   r   r   r   r   r   c          	         s   | j jjdtj| j   ddt||||||d| j  ddI dH }d|j	  kr2d	k r<n nt
t| S |j	d
krKtt
t| z| }W n ty`   t|j	|jdw t|j	|d)a/  
        Get jobs for a project.

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

            - limit: typing.Optional[int].

            - offset: typing.Optional[int].

            - include_usage_metrics: typing.Optional[bool].

            - 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_api_v_1_jobs_get()
        r    r!   r"   r   r#   r$   Nr(   r)   r*   r+   r.   r:   r   r   r   r=   [   s4   !

z)AsyncJobsClient.get_jobs_api_v_1_jobs_get)r>   r?   r@   r   r   rA   rB   rC   rD   rE   r
   r=   r   r   r   r   rG   W   rF   rG   )rA   urllib.parser1   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
   r6   __version__
startswithImportErrorpydantic.v1v1r   rG   r   r   r   r   <module>   s&   @