Package com.google.cloud.aiplatform.v1beta1

Interface PipelineServiceGrpc.AsyncService

  • All Known Implementing Classes:
    PipelineServiceGrpc.PipelineServiceImplBase
    Enclosing class:
    PipelineServiceGrpc
    public static interface PipelineServiceGrpc.AsyncService
     A service for creating and managing Vertex AI's pipelines. This includes both
 `TrainingPipeline` resources (used for AutoML and custom training) and
 `PipelineJob` resources (used for Vertex AI Pipelines).

    • Method Detail

      • createTrainingPipeline

        default void createTrainingPipeline​(CreateTrainingPipelineRequest request,
                                    io.grpc.stub.StreamObserver<TrainingPipeline> responseObserver)
         Creates a TrainingPipeline. A created TrainingPipeline right away will be
 attempted to be run.

      • deleteTrainingPipeline

        default void deleteTrainingPipeline​(DeleteTrainingPipelineRequest request,
                                    io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
         Deletes a TrainingPipeline.

      • cancelTrainingPipeline

        default void cancelTrainingPipeline​(CancelTrainingPipelineRequest request,
                                    io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
         Cancels a TrainingPipeline.
 Starts asynchronous cancellation on the TrainingPipeline. The server
 makes a best effort to cancel the pipeline, but success is not
 guaranteed. Clients can use
 [PipelineService.GetTrainingPipeline][google.cloud.aiplatform.v1beta1.PipelineService.GetTrainingPipeline]
 or other methods to check whether the cancellation succeeded or whether the
 pipeline completed despite cancellation. On successful cancellation,
 the TrainingPipeline is not deleted; instead it becomes a pipeline with
 a
 [TrainingPipeline.error][google.cloud.aiplatform.v1beta1.TrainingPipeline.error]
 value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
 corresponding to `Code.CANCELLED`, and
 [TrainingPipeline.state][google.cloud.aiplatform.v1beta1.TrainingPipeline.state]
 is set to `CANCELLED`.

      • createPipelineJob

        default void createPipelineJob​(CreatePipelineJobRequest request,
                               io.grpc.stub.StreamObserver<PipelineJob> responseObserver)
         Creates a PipelineJob. A PipelineJob will run immediately when created.

      • getPipelineJob

        default void getPipelineJob​(GetPipelineJobRequest request,
                            io.grpc.stub.StreamObserver<PipelineJob> responseObserver)
         Gets a PipelineJob.

      • deletePipelineJob

        default void deletePipelineJob​(DeletePipelineJobRequest request,
                               io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
         Deletes a PipelineJob.

      • cancelPipelineJob

        default void cancelPipelineJob​(CancelPipelineJobRequest request,
                               io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
         Cancels a PipelineJob.
 Starts asynchronous cancellation on the PipelineJob. The server
 makes a best effort to cancel the pipeline, but success is not
 guaranteed. Clients can use
 [PipelineService.GetPipelineJob][google.cloud.aiplatform.v1beta1.PipelineService.GetPipelineJob]
 or other methods to check whether the cancellation succeeded or whether the
 pipeline completed despite cancellation. On successful cancellation,
 the PipelineJob is not deleted; instead it becomes a pipeline with
 a [PipelineJob.error][google.cloud.aiplatform.v1beta1.PipelineJob.error]
 value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
 corresponding to `Code.CANCELLED`, and
 [PipelineJob.state][google.cloud.aiplatform.v1beta1.PipelineJob.state] is
 set to `CANCELLED`.