feat(cli): add support for fine_tuning.jobs

src/openai/cli/_api/_main.py

@@ -2,7 +2,7 @@
 
 from argparse import ArgumentParser
 
-from . import chat, audio, files, image, models, completions
+from . import chat, audio, files, image, models, completions, fine_tuning
 
 
 def register_commands(parser: ArgumentParser) -> None:
@@ -14,3 +14,4 @@ def register_commands(parser: ArgumentParser) -> None:
  files.register(subparsers)
  models.register(subparsers)
  completions.register(subparsers)
+ fine_tuning.register(subparsers)

src/openai/cli/_api/fine_tuning/__init__.py

@@ -0,0 +1,13 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+from argparse import ArgumentParser
+
+from . import jobs
+
+if TYPE_CHECKING:
+ from argparse import _SubParsersAction
+
+
+def register(subparser: _SubParsersAction[ArgumentParser]) -> None:
+ jobs.register(subparser)

src/openai/cli/_api/fine_tuning/jobs.py

@@ -0,0 +1,169 @@
+from __future__ import annotations
+
+import json
+from typing import TYPE_CHECKING
+from argparse import ArgumentParser
+
+from ..._utils import get_client, print_model
+from ...._types import NOT_GIVEN, NotGivenOr
+from ..._models import BaseModel
+from ....pagination import SyncCursorPage
+from ....types.fine_tuning import (
+ FineTuningJob,
+ FineTuningJobEvent,
+)
+
+if TYPE_CHECKING:
+ from argparse import _SubParsersAction
+
+
+def register(subparser: _SubParsersAction[ArgumentParser]) -> None:
+ sub = subparser.add_parser("fine_tuning.jobs.create")
+ sub.add_argument(
+ "-m",
+ "--model",
+ help="The model to fine-tune.",
+ required=True,
+ )
+ sub.add_argument(
+ "-F",
+ "--training-file",
+ help="The training file to fine-tune the model on.",
+ required=True,
+ )
+ sub.add_argument(
+ "-H",
+ "--hyperparameters",
+ help="JSON string of hyperparameters to use for fine-tuning.",
+ type=str,
+ )
+ sub.add_argument(
+ "-s",
+ "--suffix",
+ help="A suffix to add to the fine-tuned model name.",
+ )
+ sub.add_argument(
+ "-V",
+ "--validation-file",
+ help="The validation file to use for fine-tuning.",
+ )
+ sub.set_defaults(func=CLIFineTuningJobs.create, args_model=CLIFineTuningJobsCreateArgs)
+
+ sub = subparser.add_parser("fine_tuning.jobs.retrieve")
+ sub.add_argument(
+ "-i",
+ "--id",
+ help="The ID of the fine-tuning job to retrieve.",
+ required=True,
+ )
+ sub.set_defaults(func=CLIFineTuningJobs.retrieve, args_model=CLIFineTuningJobsRetrieveArgs)
+
+ sub = subparser.add_parser("fine_tuning.jobs.list")
+ sub.add_argument(
+ "-a",
+ "--after",
+ help="Identifier for the last job from the previous pagination request. If provided, only jobs created after this job will be returned.",
+ )
+ sub.add_argument(
+ "-l",
+ "--limit",
+ help="Number of fine-tuning jobs to retrieve.",
+ type=int,
+ )
+ sub.set_defaults(func=CLIFineTuningJobs.list, args_model=CLIFineTuningJobsListArgs)
+
+ sub = subparser.add_parser("fine_tuning.jobs.cancel")
+ sub.add_argument(
+ "-i",
+ "--id",
+ help="The ID of the fine-tuning job to cancel.",
+ required=True,
+ )
+ sub.set_defaults(func=CLIFineTuningJobs.cancel, args_model=CLIFineTuningJobsCancelArgs)
+
+ sub = subparser.add_parser("fine_tuning.jobs.list_events")
+ sub.add_argument(
+ "-i",
+ "--id",
+ help="The ID of the fine-tuning job to list events for.",
+ required=True,
+ )
+ sub.add_argument(
+ "-a",
+ "--after",
+ help="Identifier for the last event from the previous pagination request. If provided, only events created after this event will be returned.",
+ )
+ sub.add_argument(
+ "-l",
+ "--limit",
+ help="Number of fine-tuning job events to retrieve.",
+ type=int,
+ )
+ sub.set_defaults(func=CLIFineTuningJobs.list_events, args_model=CLIFineTuningJobsListEventsArgs)
+
+
+class CLIFineTuningJobsCreateArgs(BaseModel):
+ model: str
+ training_file: str
+ hyperparameters: NotGivenOr[str] = NOT_GIVEN
+ suffix: NotGivenOr[str] = NOT_GIVEN
+ validation_file: NotGivenOr[str] = NOT_GIVEN
+
+
+class CLIFineTuningJobsRetrieveArgs(BaseModel):
+ id: str
+
+
+class CLIFineTuningJobsListArgs(BaseModel):
+ after: NotGivenOr[str] = NOT_GIVEN
+ limit: NotGivenOr[int] = NOT_GIVEN
+
+
+class CLIFineTuningJobsCancelArgs(BaseModel):
+ id: str
+
+
+class CLIFineTuningJobsListEventsArgs(BaseModel):
+ id: str
+ after: NotGivenOr[str] = NOT_GIVEN
+ limit: NotGivenOr[int] = NOT_GIVEN
+
+
+class CLIFineTuningJobs:
+ @staticmethod
+ def create(args: CLIFineTuningJobsCreateArgs) -> None:
+ hyperparameters = json.loads(str(args.hyperparameters)) if args.hyperparameters is not NOT_GIVEN else NOT_GIVEN
+ fine_tuning_job: FineTuningJob = get_client().fine_tuning.jobs.create(
+ model=args.model,
+ training_file=args.training_file,
+ hyperparameters=hyperparameters,
+ suffix=args.suffix,
+ validation_file=args.validation_file,
+ )
+ print_model(fine_tuning_job)
+
+ @staticmethod
+ def retrieve(args: CLIFineTuningJobsRetrieveArgs) -> None:
+ fine_tuning_job: FineTuningJob = get_client().fine_tuning.jobs.retrieve(fine_tuning_job_id=args.id)
+ print_model(fine_tuning_job)
+
+ @staticmethod
+ def list(args: CLIFineTuningJobsListArgs) -> None:
+ fine_tuning_jobs: SyncCursorPage[FineTuningJob] = get_client().fine_tuning.jobs.list(
+ after=args.after or NOT_GIVEN, limit=args.limit or NOT_GIVEN
+ )
+ print_model(fine_tuning_jobs)
+
+ @staticmethod
+ def cancel(args: CLIFineTuningJobsCancelArgs) -> None:
+ fine_tuning_job: FineTuningJob = get_client().fine_tuning.jobs.cancel(fine_tuning_job_id=args.id)
+ print_model(fine_tuning_job)
+
+ @staticmethod
+ def list_events(args: CLIFineTuningJobsListEventsArgs) -> None:
+ fine_tuning_job_events: SyncCursorPage[FineTuningJobEvent] = get_client().fine_tuning.jobs.list_events(
+ fine_tuning_job_id=args.id,
+ after=args.after or NOT_GIVEN,
+ limit=args.limit or NOT_GIVEN,
+ )
+ print_model(fine_tuning_job_events)