a
    fnk                     @  sh  d dl mZ d dlmZmZmZ d dlmZ d dlZddl	m
Z
 ddlmZmZmZmZmZ ddlmZmZ dd	lmZ d
dlmZmZmZmZmZmZ ddlmZmZ ddl m!Z!m"Z" ddl#m$Z$m%Z% ddl&m'Z'm(Z( ddl)m*Z*m+Z+m,Z, ddl-m.Z. ddl/m0Z0 ddgZ1G dd deZ2G dd deZ3G dd dZ4G dd dZ5G dd dZ6G dd dZ7dS )    )annotations)UnionIterableOptional)LiteralN   )_legacy_response)	NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property   )CheckpointsAsyncCheckpointsCheckpointsWithRawResponseAsyncCheckpointsWithRawResponse CheckpointsWithStreamingResponse%AsyncCheckpointsWithStreamingResponse)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)job_list_paramsjob_create_paramsjob_list_events_params)FineTuningJob)FineTuningJobEventJobs	AsyncJobsc                   @  s  e Zd ZeddddZeddddZeddd	d
Zeeeeeddded	dddddddddddddddZdddeddddddddddZ	eedddedd d!ddddd"d#d$d%Z
dddeddddddddd&d'Zeedddeddd d!ddddd(d)d*d+ZdS ),r%   r   returnc                 C  s
   t | jS N)r   _clientself r-   _/var/www/ai-form-bot/venv/lib/python3.9/site-packages/openai/resources/fine_tuning/jobs/jobs.pycheckpoints(   s    zJobs.checkpointsJobsWithRawResponsec                 C  s   t | S r)   )r0   r+   r-   r-   r.   with_raw_response,   s    zJobs.with_raw_responseJobsWithStreamingResponsec                 C  s   t | S r)   )r2   r+   r-   r-   r.   with_streaming_response0   s    zJobs.with_streaming_responseN	hyperparametersintegrationsseedsuffixvalidation_fileextra_headersextra_query
extra_bodytimeoutQUnion[str, Literal['babbage-002', 'davinci-002', 'gpt-3.5-turbo', 'gpt-4o-mini']]str,job_create_params.Hyperparameters | NotGiven<Optional[Iterable[job_create_params.Integration]] | NotGivenOptional[int] | NotGivenOptional[str] | NotGivenHeaders | NoneQuery | NoneBody | None'float | httpx.Timeout | None | NotGivenr#   modeltraining_filer5   r6   r7   r8   r9   r:   r;   r<   r=   r(   c                C  s6   | j dt|||||||dtjt||	|
|dtdS )  
        Creates a fine-tuning job which begins the process of creating a new model from
        a given dataset.

        Response includes details of the enqueued job including job status and the name
        of the fine-tuned models once complete.

        [Learn more about fine-tuning](https://platform.openai.com/docs/guides/fine-tuning)

        Args:
          model: The name of the model to fine-tune. You can select one of the
              [supported models](https://platform.openai.com/docs/guides/fine-tuning/which-models-can-be-fine-tuned).

          training_file: The ID of an uploaded file that contains training data.

              See [upload file](https://platform.openai.com/docs/api-reference/files/create)
              for how to upload a file.

              Your dataset must be formatted as a JSONL file. Additionally, you must upload
              your file with the purpose `fine-tune`.

              The contents of the file should differ depending on if the model uses the
              [chat](https://platform.openai.com/docs/api-reference/fine-tuning/chat-input) or
              [completions](https://platform.openai.com/docs/api-reference/fine-tuning/completions-input)
              format.

              See the [fine-tuning guide](https://platform.openai.com/docs/guides/fine-tuning)
              for more details.

          hyperparameters: The hyperparameters used for the fine-tuning job.

          integrations: A list of integrations to enable for your fine-tuning job.

          seed: The seed controls the reproducibility of the job. Passing in the same seed and
              job parameters should produce the same results, but may differ in rare cases. If
              a seed is not specified, one will be generated for you.

          suffix: A string of up to 18 characters that will be added to your fine-tuned model
              name.

              For example, a `suffix` of "custom-model-name" would produce a model name like
              `ft:gpt-4o-mini:openai:custom-model-name:7p4lURel`.

          validation_file: The ID of an uploaded file that contains validation data.

              If you provide this file, the data is used to generate validation metrics
              periodically during fine-tuning. These metrics can be viewed in the fine-tuning
              results file. The same data should not be present in both train and validation
              files.

              Your dataset must be formatted as a JSONL file. You must upload your file with
              the purpose `fine-tune`.

              See the [fine-tuning guide](https://platform.openai.com/docs/guides/fine-tuning)
              for more details.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        /fine_tuning/jobsrI   rJ   r5   r6   r7   r8   r9   r:   r;   r<   r=   bodyoptionscast_to)_postr   r!   JobCreateParamsr   r#   r,   rI   rJ   r5   r6   r7   r8   r9   r:   r;   r<   r=   r-   r-   r.   create4   s$    Q	zJobs.createrN   fine_tuning_job_idr:   r;   r<   r=   r(   c                C  s4   |st d|| jd| t||||dtdS )  
        Get info about a fine-tuning job.

        [Learn more about fine-tuning](https://platform.openai.com/docs/guides/fine-tuning)

        Args:
          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        AExpected a non-empty value for `fine_tuning_job_id` but received /fine_tuning/jobs/rN   rQ   rR   
ValueError_getr   r#   r,   rX   r:   r;   r<   r=   r-   r-   r.   retrieve   s    zJobs.retrieveafterlimitr:   r;   r<   r=   str | NotGivenint | NotGivenzSyncCursorPage[FineTuningJob]rc   rd   r:   r;   r<   r=   r(   c                C  s2   | j dtt t||||t||dtjdtdS a  
        List your organization's fine-tuning jobs

        Args:
          after: Identifier for the last job from the previous pagination request.

          limit: Number of fine-tuning jobs to retrieve.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rL   rc   rd   r:   r;   r<   r=   querypagerQ   rI   )_get_api_listr   r#   r   r   r    JobListParamsr,   rc   rd   r:   r;   r<   r=   r-   r-   r.   list   s"    z	Jobs.listc                C  s6   |st d|| jd| dt||||dtdS )W  
        Immediately cancel a fine-tune job.

        Args:
          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rZ   r[   /cancelrN   r\   r^   rS   r   r#   r`   r-   r-   r.   cancel   s    
zJobs.cancelz"SyncCursorPage[FineTuningJobEvent]rX   rc   rd   r:   r;   r<   r=   r(   c                C  sL   |st d|| jd| dtt t||||t||dtjdtdS a  
        Get status updates for a fine-tuning job.

        Args:
          after: Identifier for the last event from the previous pagination request.

          limit: Number of events to retrieve.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rZ   r[   z/eventsri   rj   rl   )r^   rn   r   r$   r   r   r"   JobListEventsParamsr,   rX   rc   rd   r:   r;   r<   r=   r-   r-   r.   list_events  s&    
zJobs.list_events__name__
__module____qualname__r   r/   r1   r3   r	   rV   ra   rq   ru   rz   r-   r-   r-   r.   r%   '   sP   (k&5%c                   @  s  e Zd ZeddddZeddddZeddd	d
Zeeeeeddded	dddddddddddddddZdddeddddddddddZ	eedddedd d!ddddd"d#d$d%Z
dddeddddddddd&d'Zeedddeddd d!ddddd(d)d*d+ZdS ),r&   r   r'   c                 C  s
   t | jS r)   )r   r*   r+   r-   r-   r.   r/   @  s    zAsyncJobs.checkpointsAsyncJobsWithRawResponsec                 C  s   t | S r)   )r   r+   r-   r-   r.   r1   D  s    zAsyncJobs.with_raw_responseAsyncJobsWithStreamingResponsec                 C  s   t | S r)   )r   r+   r-   r-   r.   r3   H  s    z!AsyncJobs.with_streaming_responseNr4   r>   r?   r@   rA   rB   rC   rD   rE   rF   rG   r#   rH   c                  sB   | j dt|||||||dtjI dH t||	|
|dtdI dH S )rK   rL   rM   NrN   rO   )rS   r   r!   rT   r   r#   rU   r-   r-   r.   rV   L  s$    Q	zAsyncJobs.createrN   rW   c                  s:   |st d|| jd| t||||dtdI dH S )rY   rZ   r[   rN   r\   Nr]   r`   r-   r-   r.   ra     s    zAsyncJobs.retrieverb   re   rf   z=AsyncPaginator[FineTuningJob, AsyncCursorPage[FineTuningJob]]rg   c                C  s2   | j dtt t||||t||dtjdtdS rh   )rn   r   r#   r   r   r    ro   rp   r-   r-   r.   rq     s"    zAsyncJobs.listc                  s<   |st d|| jd| dt||||dtdI dH S )rr   rZ   r[   rs   rN   r\   Nrt   r`   r-   r-   r.   ru     s    
zAsyncJobs.cancelzGAsyncPaginator[FineTuningJobEvent, AsyncCursorPage[FineTuningJobEvent]]rv   c                C  sL   |st d|| jd| dtt t||||t||dtjdtdS rw   )r^   rn   r   r$   r   r   r"   rx   ry   r-   r-   r.   rz   $  s&    
zAsyncJobs.list_eventsr{   r-   r-   r-   r.   r&   ?  sP   (k&5%c                   @  s.   e Zd ZdddddZedddd	Zd
S )r0   r%   Nonejobsr(   c                 C  sP   || _ t|j| _t|j| _t|j| _t|j| _t|j| _d S r)   )_jobsr   Zto_raw_response_wrapperrV   ra   rq   ru   rz   r,   r   r-   r-   r.   __init__X  s     zJobsWithRawResponse.__init__r   r'   c                 C  s   t | jjS r)   )r   r   r/   r+   r-   r-   r.   r/   k  s    zJobsWithRawResponse.checkpointsNr|   r}   r~   r   r   r/   r-   r-   r-   r.   r0   W  s   r0   c                   @  s.   e Zd ZdddddZedddd	Zd
S )r   r&   r   r   c                 C  sP   || _ t|j| _t|j| _t|j| _t|j| _t|j| _d S r)   )r   r   Zasync_to_raw_response_wrapperrV   ra   rq   ru   rz   r   r-   r-   r.   r   q  s     z!AsyncJobsWithRawResponse.__init__r   r'   c                 C  s   t | jjS r)   )r   r   r/   r+   r-   r-   r.   r/     s    z$AsyncJobsWithRawResponse.checkpointsNr   r-   r-   r-   r.   r   p  s   r   c                   @  s.   e Zd ZdddddZedddd	Zd
S )r2   r%   r   r   c                 C  sF   || _ t|j| _t|j| _t|j| _t|j| _t|j| _d S r)   )r   r   rV   ra   rq   ru   rz   r   r-   r-   r.   r     s     z"JobsWithStreamingResponse.__init__r   r'   c                 C  s   t | jjS r)   )r   r   r/   r+   r-   r-   r.   r/     s    z%JobsWithStreamingResponse.checkpointsNr   r-   r-   r-   r.   r2     s   r2   c                   @  s.   e Zd ZdddddZedddd	Zd
S )r   r&   r   r   c                 C  sF   || _ t|j| _t|j| _t|j| _t|j| _t|j| _d S r)   )r   r   rV   ra   rq   ru   rz   r   r-   r-   r.   r     s     z'AsyncJobsWithStreamingResponse.__init__r   r'   c                 C  s   t | jjS r)   )r   r   r/   r+   r-   r-   r.   r/     s    z*AsyncJobsWithStreamingResponse.checkpointsNr   r-   r-   r-   r.   r     s   r   )8
__future__r   typingr   r   r   typing_extensionsr   Zhttpx r   _typesr	   r
   r   r   r   Z_utilsr   r   _compatr   r/   r   r   r   r   r   r   Z	_resourcer   r   	_responser   r   Z
paginationr   r   Z_base_clientr   r   Ztypes.fine_tuningr    r!   r"   Z!types.fine_tuning.fine_tuning_jobr#   Z'types.fine_tuning.fine_tuning_job_eventr$   __all__r%   r&   r0   r   r2   r   r-   r-   r-   r.   <module>   s4        