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