$%hddlmZddlmZmZmZmZddlmZddl Z ddl m Z ddl m Z mZmZmZmZddlmZmZdd lmZd d lmZmZmZmZmZmZdd lmZm Z dd l!m"Z"m#Z#ddl$m%Z%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddgZ4GddeZ5Gdde Z6GddZ7GddZ8GddZ9GddZ:y) ) annotations)DictUnionIterableOptional)LiteralN)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property) CheckpointsAsyncCheckpointsCheckpointsWithRawResponseAsyncCheckpointsWithRawResponse CheckpointsWithStreamingResponse%AsyncCheckpointsWithStreamingResponse)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)job_list_paramsjob_create_paramsjob_list_events_params)Metadata) FineTuningJob)FineTuningJobEventJobs AsyncJobsc eZdZeddZeddZeddZeeeeeeeddded ddZddded ddZ eeeddded  dd Z ddded dd Z eeddded  dd Z ddded ddZ ddded ddZy)r(c,t|jSN)r_clientselfs d/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/openai/resources/fine_tuning/jobs/jobs.py checkpointszJobs.checkpoints&s4<<((ct|Sa This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers )JobsWithRawResponser.s r0with_raw_responsezJobs.with_raw_response*s#4((r2ct|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )JobsWithStreamingResponser.s r0with_streaming_responsezJobs.with_streaming_response4s)..r2N hyperparameters integrationsmetadatamethodseedsuffixvalidation_file extra_headers extra_query extra_bodytimeoutc |jdt||||||||| d tjt | | | | t 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), [completions](https://platform.openai.com/docs/api-reference/fine-tuning/completions-input) format, or if the fine-tuning method uses the [preference](https://platform.openai.com/docs/api-reference/fine-tuning/preference-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. This value is now deprecated in favor of `method`, and should be passed in under the `method` parameter. integrations: A list of integrations to enable for your fine-tuning job. metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format, and querying for objects via API or the dashboard. Keys are strings with a maximum length of 64 characters. Values are strings with a maximum length of 512 characters. method: The method used for fine-tuning. 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 64 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 model training_filer<r=r>r?r@rArBrCrDrErFbodyoptionscast_to)_postrr#JobCreateParamsr!r&r/rKrLr<r=r>r?r@rArBrCrDrErFs r0createz Jobs.create=sk~zz  "%2'6$0 ($ $'6 "11 )+Q[el"'  r2rMc r|std||jd|t||||tS) 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/rMrPrQ ValueError_getr!r&r/fine_tuning_job_idrCrDrErFs r0retrievez Jobs.retrievesV2"`as`vwx xyy !3 4 5(+Q[el"   r2afterlimitr>rCrDrErFc|jdttt||||t |||dt j tSa 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. metadata: Optional metadata filter. To filter, use the syntax `metadata[k]=v`. Alternatively, set `metadata=null` to indicate no metadata. 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 rI)rbrcr>rCrDrErFquerypagerPrK) _get_api_listrr&r!rr" JobListParamsr/rbrcr>rCrDrErFs r0listz Jobs.listsb@!!  .(+'%%!&!&$, $11   #"  r2c t|std||jd|dt||||tS)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 rXrY/cancelrMrZr\rRr!r&r^s r0cancelz Jobs.cancel X."`as`vwx xzz !3 4G <(+Q[el"   r2rbrcrCrDrErFc|std||jd|dttt ||||t ||dt jtSa 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 rXrYz/events)rbrcrfrh)r\rjrr'r!rr$JobListEventsParamsr/r_rbrcrCrDrErFs r0 list_eventszJobs.list_events*s:"`as`vwx x!! !3 4G < 23(+'%%!&!&+>>  %!"  r2c t|std||jd|dt||||tS)J Pause 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 rXrY/pauserMrZrqr^s r0pausez Jobs.pause\sX."`as`vwx xzz !3 4F ;(+Q[el"   r2c t|std||jd|dt||||tS)K Resume 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 rXrY/resumerMrZrqr^s r0resumez Jobs.resume}rsr2)returnr)rr5)rr9rKzQUnion[str, Literal['babbage-002', 'davinci-002', 'gpt-3.5-turbo', 'gpt-4o-mini']]rLstrr<z,job_create_params.Hyperparameters | NotGivenr=zzOptional[Metadata] | NotGivenr?z#job_create_params.Method | NotGivenr@zOptional[int] | NotGivenrAOptional[str] | NotGivenrBrrCHeaders | NonerD Query | NonerE Body | NonerF'float | httpx.Timeout | None | NotGivenrr& r_rrCrrDrrErrFrrr&)rbstr | NotGivenrcint | NotGivenr>#Optional[Dict[str, str]] | NotGivenrCrrDrrErrFrrzSyncCursorPage[FineTuningJob])r_rrbrrcrrCrrDrrErrFrrz"SyncCursorPage[FineTuningJobEvent]__name__ __module__ __qualname__rr1r6r:r rUr`rmrrryr}rr2r0r(r(%s))))//IRU^2;6?)2+44=)-$("&;D#s as  s F s S s 0s 4s 's )s 2s &s "s  !s "9#s $ %s v)-$("&;D! ! & ! "!  ! 9!  ! L!* )8A)-$("&;D2 2  2 6 2 &2 "2  2 92  '2 t)-$("&;D  &  "   9   J!* ))-$("&;D0 0  0  0 &0 "0  0 90  ,0 p)-$("&;D  &  "   9   N)-$("&;D  &  "   9   r2c eZdZeddZeddZeddZeeeeeeeddded ddZddded ddZ eeeddded  dd Z ddded dd Z eeddded  dd Z ddded ddZ ddded ddZy)r)c,t|jSr,)rr-r.s r0r1zAsyncJobs.checkpointss --r2ct|Sr4)AsyncJobsWithRawResponser.s r0r6zAsyncJobs.with_raw_responses(--r2ct|Sr8)AsyncJobsWithStreamingResponser.s r0r:z!AsyncJobs.with_streaming_responses.d33r2Nr;c K|jdt||||||||| d tjd{t | | | | t d{S7$7w)rHrIrJNrMrN)rRrr#rSr!r&rTs r0rUzAsyncJobs.creates~ZZ ,"%2'6$0 ($ $'6 "11  )+Q[el"'      s!4AA AAAArMc K|std||jd|t||||td{S7w)rWrXrYrMrZNr[r^s r0r`zAsyncJobs.retrieve,sd2"`as`vwx xYY !3 4 5(+Q[el"     s>  %!"  r2c K|std||jd|dt||||td{S7w)r{rXrYr|rMrZNrqr^s r0r}zAsyncJobs.pausesf."`as`vwx xZZ !3 4F ;(+Q[el"      rc K|std||jd|dt||||td{S7w)rrXrYrrMrZNrqr^s r0rzAsyncJobs.resumerr)rr)rr)rrrr)rbrrcrr>rrCrrDrrErrFrrz=AsyncPaginator[FineTuningJob, AsyncCursorPage[FineTuningJob]])r_rrbrrcrrCrrDrrErrFrrzGAsyncPaginator[FineTuningJobEvent, AsyncCursorPage[FineTuningJobEvent]]rrr2r0r)r)s....44IRU^2;6?)2+44=)-$("&;D#s as  s F s S s 0s 4s 's )s 2s &s "s  !s "9#s $ %s v)-$("&;D! ! & ! "!  ! 9!  ! L!* )8A)-$("&;D2 2  2 6 2 &2 "2  2 92  G2 t)-$("&;D  &  "   9   J!* ))-$("&;D0 0  0  0 &0 "0  0 90  Q0 p)-$("&;D  &  "   9   N)-$("&;D  &  "   9   r2c&eZdZddZeddZy)r5c ||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_tj|j|_ yr,) _jobsr to_raw_response_wrapperrUr`rmrrryr}rr/jobss r0__init__zJobsWithRawResponse.__init__s &>> KK  )@@ MM  %<< II  '>> KK  ,CC    &== JJ  '>> KK  r2c@t|jjSr,)rrr1r.s r0r1zJobsWithRawResponse.checkpoints3s)$***@*@AAr2Nrr(rNone)rrrrrrrr1rr2r0r5r5s 2BBr2r5c&eZdZddZeddZy)rc ||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_tj|j|_tj|j|_ yr,) rr async_to_raw_response_wrapperrUr`rmrrryr}rrs r0rz!AsyncJobsWithRawResponse.__init__9s &DD KK  )FF MM  %BB II  'DD KK  ,II    &CC JJ  'DD KK  r2c@t|jjSr,)rrr1r.s r0r1z$AsyncJobsWithRawResponse.checkpointsRs.tzz/E/EFFr2Nrr)rr)rrrrr2r0rr8s 2GGr2rc&eZdZddZeddZy)r9c~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr,) rrrUr`rmrrryr}rrs r0rz"JobsWithStreamingResponse.__init__Xs 2 KK  5 MM  1 II  3 KK  8    2 JJ  3 KK  r2c@t|jjSr,)rrr1r.s r0r1z%JobsWithStreamingResponse.checkpointsqs/ 0F0FGGr2Nr)rrrrr2r0r9r9Ws 2HHr2r9c&eZdZddZeddZy)rc~||_t|j|_t|j|_t|j|_t|j |_t|j |_t|j|_t|j|_yr,) rrrUr`rmrrryr}rrs r0rz'AsyncJobsWithStreamingResponse.__init__ws 8 KK  ; MM  7 II  9 KK  >    8 JJ  9 KK  r2c@t|jjSr,)rrr1r.s r0r1z*AsyncJobsWithStreamingResponse.checkpointss4TZZ5K5KLLr2Nr)rrrrr2r0rrvs 2MMr2r); __future__rtypingrrrrtyping_extensionsrhttpxr _typesr r r rr_utilsrr_compatrr1rrrrrr _resourcerr _responserr paginationrr _base_clientr r!types.fine_tuningr"r#r$types.shared_params.metadatar%!types.fine_tuning.fine_tuning_jobr&'types.fine_tuning.fine_tuning_job_eventr'__all__r(r)r5rr9rrr2r0rs#22% !@@='<Z:]\5?J ; w ?w t w  w t BB>GG>HH>MMr2