o
    i^q                     @   s   d 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
mZ ddlmZ dd	lmZ dd
lmZmZmZmZmZ G dd deZdS )zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.   )BaseSDK    )datetime)modelsutils)HookContext)OptionalNullableUNSET)get_security_from_env)unmarshal_json_response)AnyDictListMappingOptionalc                   @   s  e Zd Zddeeeedeedddddee dee dee d	ee d
eeee	f  dee
 dee deeej  deej dee dee deeeef  dejfddZddeeeedeedddddee dee dee d	ee d
eeee	f  dee
 dee deeej  deej dee dee deeeef  dejfddZeeededddddee dejdee d	ee d
eeeef  dee deej dee dee deeeef  dejfddZeeededddddee dejdee d	ee d
eeeef  dee deej dee dee deeeef  dejfddZedddd d!edeej dee dee deeeef  dejfd"d#Zedddd d!edeej dee dee deeeef  dejfd$d%Zedddd d!edeej dee dee deeeef  dejfd&d'Zedddd d!edeej dee dee deeeef  dejfd(d)ZdS )*MistralJobsr   d   FN)page	page_sizemodelagent_idmetadatacreated_aftercreated_by_mestatusretries
server_url
timeout_mshttp_headersr   r   r   r   r   r   r   r   r   r   r   r   returnc                C   sT  d}d}|du r| j j}|
dur|
}n| ||}tj||||||||d}| jdd|||ddddd|| j j|d	}|	tkrH| j jturH| j j}	d}t	|	t
jrV|	g d
f}| jt| j |p^ddg t| j jtjd|ddg|d}t
|ddr~ttj|S t
|ddrt
|}td||t
|ddrt
|}td||td|a}  Get Batch Jobs

        Get a list of batch jobs for your organization and user.

        :param page:
        :param page_size:
        :param model:
        :param agent_id:
        :param metadata:
        :param created_after:
        :param created_by_me:
        :param status:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        N)r   r   r   r   r   r   r   r   GET/v1/batch/jobsFT
user-agentapplication/jsonmethodpathbase_urlurl_variablesrequestrequest_body_requiredrequest_has_path_paramsrequest_has_query_paramsuser_agent_headeraccept_header_valuer   securityr   429500502503504 $jobs_api_routes_batch_get_batch_jobsconfigr(   operation_idoauth2_scopessecurity_source4XX5XXhook_ctxr*   error_status_codesretry_config200*API error occurredUnexpected response received)sdk_configurationr   _get_urlr   %JobsAPIRoutesBatchGetBatchJobsRequest_build_requestr0   r	   rC   
isinstancer   RetryConfig
do_requestr   r
   Securitymatch_responser   BatchJobsOutstream_to_textSDKErrorselfr   r   r   r   r   r   r   r   r   r   r   r   r(   r)   r*   reqrC   http_reshttp_res_text rY   \/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/mistralai/mistral_jobs.pylist   sz   !
	

zMistralJobs.listc                   sh  d}d}|du r| j j}|
dur|
}n| ||}tj||||||||d}| jdd|||ddddd|| j j|d	}|	tkrI| j jturI| j j}	d}t	|	t
jrW|	g d
f}| jt| j |p_ddg t| j jtjd|ddg|dI dH }t
|ddrttj|S t
|ddrt
|I dH }td||t
|ddrt
|I dH }td||td|r    )rH   r   rI   r   rJ   _build_request_asyncr0   r	   rC   rL   r   rM   do_request_asyncr   r
   rO   rP   r   rQ   stream_to_text_asyncrS   rT   rY   rY   rZ   
list_asyncv   s|   !
	zMistralJobs.list_async   )r   r   r   timeout_hoursr   r   r   r   input_filesendpointra   c       
            sZ  d}d}|	du r| j j}	|dur|}n| ||}tj||||||d | jdd|| ddddd|
| j j fd	d
|	d}|tkrK| j jturK| j j}d}t	|t
jrY|g df}| jt| j |paddg t| j jtjd|ddg|d}t
|ddrttj|S t
|ddrt
|}td||t
|ddrt
|}td||td|)Q  Create Batch Job

        Create a new batch job, it will be queued for processing.

        :param input_files:
        :param endpoint:
        :param model:
        :param agent_id:
        :param metadata:
        :param timeout_hours:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nrb   rc   r   r   r   ra   POSTr"   TFr#   r$   c                         t  dddtjS NFjsonr   serialize_request_bodyr   
BatchJobInrY   r*   rY   rZ   <lambda>      z$MistralJobs.create.<locals>.<lambda>r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r   r0   get_serialized_bodyr   r1   r7   &jobs_api_routes_batch_create_batch_jobr9   r>   r?   r@   rD   rE   rF   rG   )rH   r   rI   r   rl   rK   r0   r	   rC   rL   r   rM   rN   r   r
   rO   rP   r   BatchJobOutrR   rS   rU   rb   rc   r   r   r   ra   r   r   r   r   r(   r)   rV   rC   rW   rX   rY   rm   rZ   create   sx   	

	

zMistralJobs.createc       
            sn  d}d}|	du r| j j}	|dur|}n| ||}tj||||||d | jdd|| ddddd|
| j j fd	d
|	d}|tkrL| j jturL| j j}d}t	|t
jrZ|g df}| jt| j |pbddg t| j jtjd|ddg|dI dH }t
|ddrttj|S t
|ddrt
|I dH }td||t
|ddrt
|I dH }td||td|)rd   Nre   rf   r"   TFr#   r$   c                      rg   rh   rj   rY   rm   rY   rZ   rn     ro   z*MistralJobs.create_async.<locals>.<lambda>rp   r1   r7   rr   r9   r>   r?   r@   rD   rE   rF   rG   )rH   r   rI   r   rl   r\   r0   r	   rC   rL   r   rM   r]   r   r
   rO   rP   r   rs   r^   rS   rt   rY   rm   rZ   create_asyncC  sz   	

	zMistralJobs.create_async)r   r   r   r   job_idc                C   F  d}d}|du r| j j}|dur|}n| ||}tj|d}| jdd|||ddddd|| j j|d	}	|tkrA| j jturA| j j}d}
t	|t
jrO|g d
f}
| jt| j |pWddg t| j jtjd|	ddg|
d}t
|ddrwttj|S t
|ddrt
|}td||t
|ddrt
|}td||td|a  Get Batch Job

        Get a batch job details by its UUID.

        :param job_id:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nrw   r!   z/v1/batch/jobs/{job_id}FTr#   r$   r%   r1   r7   #jobs_api_routes_batch_get_batch_jobr9   r>   r?   r@   rD   rE   rF   rG   )rH   r   rI   r   $JobsAPIRoutesBatchGetBatchJobRequestrK   r0   r	   rC   rL   r   rM   rN   r   r
   rO   rP   r   rs   rR   rS   rU   rw   r   r   r   r   r(   r)   r*   rV   rC   rW   rX   rY   rY   rZ   get  l   
	

zMistralJobs.getc                   Z  d}d}|du r| j j}|dur|}n| ||}tj|d}| jdd|||ddddd|| j j|d	}	|tkrB| j jturB| j j}d}
t	|t
jrP|g d
f}
| jt| j |pXddg t| j jtjd|	ddg|
dI dH }t
|ddr{ttj|S t
|ddrt
|I dH }td||t
|ddrt
|I dH }td||td|ry   )rH   r   rI   r   r|   r\   r0   r	   rC   rL   r   rM   r]   r   r
   rO   rP   r   rs   r^   rS   r}   rY   rY   rZ   	get_async  n   
	zMistralJobs.get_asyncc                C   rx   a  Cancel Batch Job

        Request the cancellation of a batch job.

        :param job_id:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nrz   rf   z/v1/batch/jobs/{job_id}/cancelFTr#   r$   r%   r1   r7   &jobs_api_routes_batch_cancel_batch_jobr9   r>   r?   r@   rD   rE   rF   rG   )rH   r   rI   r   'JobsAPIRoutesBatchCancelBatchJobRequestrK   r0   r	   rC   rL   r   rM   rN   r   r
   rO   rP   r   rs   rR   rS   r}   rY   rY   rZ   cancelN  r   zMistralJobs.cancelc                   r   r   )rH   r   rI   r   r   r\   r0   r	   rC   rL   r   rM   r]   r   r
   rO   rP   r   rs   r^   rS   r}   rY   rY   rZ   cancel_async  r   zMistralJobs.cancel_async)__name__
__module____qualname__r	   r   intr   strr   r   r   boolr   r   BatchJobStatusr   rM   r   rQ   r[   r_   APIEndpointrs   ru   rv   r~   r   r   r   rY   rY   rY   rZ   r      s   	

k	

m	

j	

i
W
W
Wr   N)__doc__basesdkr   r   	mistralair   r   mistralai._hooksr   mistralai.typesr   r	   mistralai.utilsr
   'mistralai.utils.unmarshal_json_responser   typingr   r   r   r   r   r   rY   rY   rY   rZ   <module>   s    