Skip to main content

Jobs API Reference

This page documents the gRPC services that back job submission and lifecycle management in Michelangelo AI. Two services are defined in proto/api/v2/:

  • RayJobService — create, inspect, and delete Ray training or batch inference jobs.
  • SparkJobService — create, inspect, and delete Spark ETL and batch processing jobs.

New to this reference? See How to Read the gRPC API Reference for the shared CRUD-plus-list pattern, the Required column, and how undocumented fields are shown. For how jobs run end-to-end, see Michelangelo AI Jobs.


RayJobService​

RayJob Service defines the RayJob related methods, such as CRUD and list.

Proto source: proto/api/v2/ray_job_svc.proto

CreateRayJob​

CreateRayJob(CreateRayJobRequest) → CreateRayJobResponse

Create a new RayJob with the given spec.

Request fields

FieldTypeRequiredDescription
ray_jobRayJobYesThe metadata and spec of the RayJob to be created.
create_optionsk8s.io.apimachinery.pkg.apis.meta.v1.CreateOptionsNo—

Response fields

FieldTypeDescription
ray_jobRayJobThe created RayJob.

GetRayJob​

GetRayJob(GetRayJobRequest) → GetRayJobResponse

Get the specified RayJob.

Request fields

FieldTypeRequiredDescription
namestringYesName of the RayJob.
namespacestringYesObject name and auth scope.
get_optionsk8s.io.apimachinery.pkg.apis.meta.v1.GetOptionsNo—

Response fields

FieldTypeDescription
ray_jobRayJobThe requested RayJob.

UpdateRayJob​

UpdateRayJob(UpdateRayJobRequest) → UpdateRayJobResponse

Update a RayJob with the given spec.

Request fields

FieldTypeRequiredDescription
ray_jobRayJobYesThe metadata and spec of the RayJob to be updated.
update_optionsk8s.io.apimachinery.pkg.apis.meta.v1.UpdateOptionsNo—

Response fields

FieldTypeDescription
ray_jobRayJobThe updated RayJob.

DeleteRayJob​

DeleteRayJob(DeleteRayJobRequest) → DeleteRayJobResponse

Delete a RayJob.

Request fields

FieldTypeRequiredDescription
namestringYesName of the RayJob.
namespacestringYesObject name and auth scope.
delete_optionsk8s.io.apimachinery.pkg.apis.meta.v1.DeleteOptionsNo—

Response fields

The response message carries no fields.


DeleteRayJobCollection​

DeleteRayJobCollection(DeleteRayJobCollectionRequest) → DeleteRayJobCollectionResponse

Delete collection of RayJob.

Request fields

FieldTypeRequiredDescription
namespacestringYesObject name and auth scope.
delete_optionsk8s.io.apimachinery.pkg.apis.meta.v1.DeleteOptionsNo—
list_optionsk8s.io.apimachinery.pkg.apis.meta.v1.ListOptionsNo—

Response fields

The response message carries no fields.


ListRayJob​

ListRayJob(ListRayJobRequest) → ListRayJobResponse

List objects of type RayJob.

Note: Watch and list across all namespaces are not supported.

Request fields

FieldTypeRequiredDescription
namespacestringYes—
list_optionsk8s.io.apimachinery.pkg.apis.meta.v1.ListOptionsNo—
list_options_extmichelangelo.api.ListOptionsExtNo—

Response fields

FieldTypeDescription
ray_job_listRayJobList—

SparkJobService​

SparkJob Service defines the SparkJob related methods, such as CRUD and list.

Proto source: proto/api/v2/spark_job_svc.proto

CreateSparkJob​

CreateSparkJob(CreateSparkJobRequest) → CreateSparkJobResponse

Create a new SparkJob with the given spec.

Request fields

FieldTypeRequiredDescription
spark_jobSparkJobYesThe metadata and spec of the SparkJob to be created.
create_optionsk8s.io.apimachinery.pkg.apis.meta.v1.CreateOptionsNo—

Response fields

FieldTypeDescription
spark_jobSparkJobThe created SparkJob.

GetSparkJob​

GetSparkJob(GetSparkJobRequest) → GetSparkJobResponse

Get the specified SparkJob.

Request fields

FieldTypeRequiredDescription
namestringYesName of the SparkJob.
namespacestringYesObject name and auth scope.
get_optionsk8s.io.apimachinery.pkg.apis.meta.v1.GetOptionsNo—

Response fields

FieldTypeDescription
spark_jobSparkJobThe requested SparkJob.

UpdateSparkJob​

UpdateSparkJob(UpdateSparkJobRequest) → UpdateSparkJobResponse

Update a SparkJob with the given spec.

Request fields

FieldTypeRequiredDescription
spark_jobSparkJobYesThe metadata and spec of the SparkJob to be updated.
update_optionsk8s.io.apimachinery.pkg.apis.meta.v1.UpdateOptionsNo—

Response fields

FieldTypeDescription
spark_jobSparkJobThe updated SparkJob.

DeleteSparkJob​

DeleteSparkJob(DeleteSparkJobRequest) → DeleteSparkJobResponse

Delete a SparkJob.

Request fields

FieldTypeRequiredDescription
namestringYesName of the SparkJob.
namespacestringYesObject name and auth scope.
delete_optionsk8s.io.apimachinery.pkg.apis.meta.v1.DeleteOptionsNo—

Response fields

The response message carries no fields.


DeleteSparkJobCollection​

DeleteSparkJobCollection(DeleteSparkJobCollectionRequest) → DeleteSparkJobCollectionResponse

Delete collection of SparkJob.

Request fields

FieldTypeRequiredDescription
namespacestringYesObject name and auth scope.
delete_optionsk8s.io.apimachinery.pkg.apis.meta.v1.DeleteOptionsNo—
list_optionsk8s.io.apimachinery.pkg.apis.meta.v1.ListOptionsNo—

Response fields

The response message carries no fields.


ListSparkJob​

ListSparkJob(ListSparkJobRequest) → ListSparkJobResponse

List objects of type SparkJob.

Note: Watch and list across all namespaces are not supported.

Request fields

FieldTypeRequiredDescription
namespacestringYes—
list_optionsk8s.io.apimachinery.pkg.apis.meta.v1.ListOptionsNo—
list_options_extmichelangelo.api.ListOptionsExtNo—

Response fields

FieldTypeDescription
spark_job_listSparkJobList—

Next Steps​