From 666c09498e39d570df5f93ca02e169c43c9111f8 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Tue, 16 Jun 2020 14:58:12 -0700 Subject: [PATCH] fix: migrate scheduler/v1beta1 to grpc_service_config (#167) This PR was generated using Autosynth. :rainbow: Synth log will be available here: https://source.cloud.google.com/results/invocations/2c593734-539a-435d-8a04-27f04c90082f/targets - [ ] To automatically regenerate this PR, check this box. PiperOrigin-RevId: 316713534 Source-Link: https://github.com/googleapis/googleapis/commit/88ee692c9acb9b40bfd44a34fece543d472d2182 --- .../v1beta1/CloudSchedulerClient.java | 666 +++++++++--------- .../v1beta1/CloudSchedulerSettings.java | 66 +- .../cloud/scheduler/v1beta1/package-info.java | 2 +- .../v1beta1/stub/CloudSchedulerStub.java | 24 +- .../stub/CloudSchedulerStubSettings.java | 182 ++--- .../v1beta1/stub/GrpcCloudSchedulerStub.java | 168 ++--- .../v1beta1/CloudSchedulerClientTest.java | 168 ++--- synth.metadata | 6 +- 8 files changed, 647 insertions(+), 635 deletions(-) diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java index 90f0891c..b65b2deb 100644 --- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java +++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java @@ -47,7 +47,7 @@ * * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) { * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]"); - * cloudSchedulerClient.deleteJob(name); + * Job response = cloudSchedulerClient.getJob(name); * } * * @@ -158,110 +158,143 @@ public CloudSchedulerStub getStub() { // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Deletes a job. + * Lists jobs. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   cloudSchedulerClient.deleteJob(name);
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
    * }
    * 
* - * @param name Required. The job name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. + * @param parent Required. The location name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void deleteJob(JobName name) { - DeleteJobRequest request = - DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); - deleteJob(request); + public final ListJobsPagedResponse listJobs(LocationName parent) { + ListJobsRequest request = + ListJobsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build(); + return listJobs(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Deletes a job. + * Lists jobs. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   cloudSchedulerClient.deleteJob(name.toString());
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
    * }
    * 
* - * @param name Required. The job name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. + * @param parent Required. The location name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void deleteJob(String name) { - DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build(); - deleteJob(request); + public final ListJobsPagedResponse listJobs(String parent) { + ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build(); + return listJobs(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Deletes a job. + * Lists jobs. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   DeleteJobRequest request = DeleteJobRequest.newBuilder()
-   *     .setName(name.toString())
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   ListJobsRequest request = ListJobsRequest.newBuilder()
+   *     .setParent(parent.toString())
    *     .build();
-   *   cloudSchedulerClient.deleteJob(request);
+   *   for (Job element : cloudSchedulerClient.listJobs(request).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void deleteJob(DeleteJobRequest request) { - deleteJobCallable().call(request); + public final ListJobsPagedResponse listJobs(ListJobsRequest request) { + return listJobsPagedCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Deletes a job. + * Lists jobs. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   DeleteJobRequest request = DeleteJobRequest.newBuilder()
-   *     .setName(name.toString())
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   ListJobsRequest request = ListJobsRequest.newBuilder()
+   *     .setParent(parent.toString())
    *     .build();
-   *   ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
+   *   ApiFuture<ListJobsPagedResponse> future = cloudSchedulerClient.listJobsPagedCallable().futureCall(request);
    *   // Do something
-   *   future.get();
+   *   for (Job element : future.get().iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
    * }
    * 
*/ - public final UnaryCallable deleteJobCallable() { - return stub.deleteJobCallable(); + public final UnaryCallable listJobsPagedCallable() { + return stub.listJobsPagedCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Pauses a job. + * Lists jobs. * - *

If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + *

Sample code: + * + *


+   * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   ListJobsRequest request = ListJobsRequest.newBuilder()
+   *     .setParent(parent.toString())
+   *     .build();
+   *   while (true) {
+   *     ListJobsResponse response = cloudSchedulerClient.listJobsCallable().call(request);
+   *     for (Job element : response.getJobsList()) {
+   *       // doThingsWith(element);
+   *     }
+   *     String nextPageToken = response.getNextPageToken();
+   *     if (!Strings.isNullOrEmpty(nextPageToken)) {
+   *       request = request.toBuilder().setPageToken(nextPageToken).build();
+   *     } else {
+   *       break;
+   *     }
+   *   }
+   * }
+   * 
+ */ + public final UnaryCallable listJobsCallable() { + return stub.listJobsCallable(); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD + /** + * Gets a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.pauseJob(name);
+   *   Job response = cloudSchedulerClient.getJob(name);
    * }
    * 
* @@ -269,28 +302,22 @@ public final UnaryCallable deleteJobCallable() { * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job pauseJob(JobName name) { - PauseJobRequest request = - PauseJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); - return pauseJob(request); + public final Job getJob(JobName name) { + GetJobRequest request = + GetJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); + return getJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Pauses a job. - * - *

If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.pauseJob(name.toString());
+   *   Job response = cloudSchedulerClient.getJob(name.toString());
    * }
    * 
* @@ -298,321 +325,271 @@ public final Job pauseJob(JobName name) { * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job pauseJob(String name) { - PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build(); - return pauseJob(request); + public final Job getJob(String name) { + GetJobRequest request = GetJobRequest.newBuilder().setName(name).build(); + return getJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Pauses a job. - * - *

If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   PauseJobRequest request = PauseJobRequest.newBuilder()
+   *   GetJobRequest request = GetJobRequest.newBuilder()
    *     .setName(name.toString())
    *     .build();
-   *   Job response = cloudSchedulerClient.pauseJob(request);
+   *   Job response = cloudSchedulerClient.getJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job pauseJob(PauseJobRequest request) { - return pauseJobCallable().call(request); + public final Job getJob(GetJobRequest request) { + return getJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Pauses a job. - * - *

If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   PauseJobRequest request = PauseJobRequest.newBuilder()
+   *   GetJobRequest request = GetJobRequest.newBuilder()
    *     .setName(name.toString())
    *     .build();
-   *   ApiFuture<Job> future = cloudSchedulerClient.pauseJobCallable().futureCall(request);
+   *   ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
    *   // Do something
    *   Job response = future.get();
    * }
    * 
*/ - public final UnaryCallable pauseJobCallable() { - return stub.pauseJobCallable(); + public final UnaryCallable getJobCallable() { + return stub.getJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Resume a job. - * - *

This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.resumeJob(name);
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   Job job = Job.newBuilder().build();
+   *   Job response = cloudSchedulerClient.createJob(parent, job);
    * }
    * 
* - * @param name Required. The job name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. + * @param parent Required. The location name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID`. + * @param job Required. The job to add. The user can optionally specify a name for the job in + * [name][google.cloud.scheduler.v1beta1.Job.name]. + * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a + * name is not specified then the system will generate a random unique name that will be + * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job resumeJob(JobName name) { - ResumeJobRequest request = - ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); - return resumeJob(request); + public final Job createJob(LocationName parent, Job job) { + CreateJobRequest request = + CreateJobRequest.newBuilder() + .setParent(parent == null ? null : parent.toString()) + .setJob(job) + .build(); + return createJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Resume a job. - * - *

This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.resumeJob(name.toString());
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   Job job = Job.newBuilder().build();
+   *   Job response = cloudSchedulerClient.createJob(parent.toString(), job);
    * }
    * 
* - * @param name Required. The job name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. + * @param parent Required. The location name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID`. + * @param job Required. The job to add. The user can optionally specify a name for the job in + * [name][google.cloud.scheduler.v1beta1.Job.name]. + * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a + * name is not specified then the system will generate a random unique name that will be + * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job resumeJob(String name) { - ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build(); - return resumeJob(request); + public final Job createJob(String parent, Job job) { + CreateJobRequest request = CreateJobRequest.newBuilder().setParent(parent).setJob(job).build(); + return createJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Resume a job. - * - *

This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   ResumeJobRequest request = ResumeJobRequest.newBuilder()
-   *     .setName(name.toString())
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   Job job = Job.newBuilder().build();
+   *   CreateJobRequest request = CreateJobRequest.newBuilder()
+   *     .setParent(parent.toString())
+   *     .setJob(job)
    *     .build();
-   *   Job response = cloudSchedulerClient.resumeJob(request);
+   *   Job response = cloudSchedulerClient.createJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job resumeJob(ResumeJobRequest request) { - return resumeJobCallable().call(request); + public final Job createJob(CreateJobRequest request) { + return createJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Resume a job. - * - *

This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   ResumeJobRequest request = ResumeJobRequest.newBuilder()
-   *     .setName(name.toString())
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   Job job = Job.newBuilder().build();
+   *   CreateJobRequest request = CreateJobRequest.newBuilder()
+   *     .setParent(parent.toString())
+   *     .setJob(job)
    *     .build();
-   *   ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
+   *   ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
    *   // Do something
    *   Job response = future.get();
    * }
    * 
*/ - public final UnaryCallable resumeJobCallable() { - return stub.resumeJobCallable(); + public final UnaryCallable createJobCallable() { + return stub.createJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Lists jobs. - * - *

Sample code: + * Updates a job. * - *


-   * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
-   *     // doThingsWith(element);
-   *   }
-   * }
-   * 
+ *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. * - * @param parent Required. The location name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - */ - public final ListJobsPagedResponse listJobs(LocationName parent) { - ListJobsRequest request = - ListJobsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build(); - return listJobs(request); - } - - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Lists jobs. + *

If UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
-   *     // doThingsWith(element);
-   *   }
+   *   Job job = Job.newBuilder().build();
+   *   FieldMask updateMask = FieldMask.newBuilder().build();
+   *   Job response = cloudSchedulerClient.updateJob(job, updateMask);
    * }
    * 
* - * @param parent Required. The location name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID`. + * @param job Required. The new job properties. [name][google.cloud.scheduler.v1beta1.Job.name] + * must be specified. + *

Output only fields cannot be modified using UpdateJob. Any value specified for an output + * only field will be ignored. + * @param updateMask A mask used to specify which fields of the job are being updated. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final ListJobsPagedResponse listJobs(String parent) { - ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build(); - return listJobs(request); + public final Job updateJob(Job job, FieldMask updateMask) { + UpdateJobRequest request = + UpdateJobRequest.newBuilder().setJob(job).setUpdateMask(updateMask).build(); + return updateJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Lists jobs. + * Updates a job. + * + *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. + * + *

If UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   ListJobsRequest request = ListJobsRequest.newBuilder()
-   *     .setParent(parent.toString())
+   *   Job job = Job.newBuilder().build();
+   *   UpdateJobRequest request = UpdateJobRequest.newBuilder()
+   *     .setJob(job)
    *     .build();
-   *   for (Job element : cloudSchedulerClient.listJobs(request).iterateAll()) {
-   *     // doThingsWith(element);
-   *   }
+   *   Job response = cloudSchedulerClient.updateJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final ListJobsPagedResponse listJobs(ListJobsRequest request) { - return listJobsPagedCallable().call(request); + public final Job updateJob(UpdateJobRequest request) { + return updateJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Lists jobs. + * Updates a job. * - *

Sample code: + *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. * - *


-   * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   ListJobsRequest request = ListJobsRequest.newBuilder()
-   *     .setParent(parent.toString())
-   *     .build();
-   *   ApiFuture<ListJobsPagedResponse> future = cloudSchedulerClient.listJobsPagedCallable().futureCall(request);
-   *   // Do something
-   *   for (Job element : future.get().iterateAll()) {
-   *     // doThingsWith(element);
-   *   }
-   * }
-   * 
- */ - public final UnaryCallable listJobsPagedCallable() { - return stub.listJobsPagedCallable(); - } - - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Lists jobs. + *

If UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   ListJobsRequest request = ListJobsRequest.newBuilder()
-   *     .setParent(parent.toString())
+   *   Job job = Job.newBuilder().build();
+   *   UpdateJobRequest request = UpdateJobRequest.newBuilder()
+   *     .setJob(job)
    *     .build();
-   *   while (true) {
-   *     ListJobsResponse response = cloudSchedulerClient.listJobsCallable().call(request);
-   *     for (Job element : response.getJobsList()) {
-   *       // doThingsWith(element);
-   *     }
-   *     String nextPageToken = response.getNextPageToken();
-   *     if (!Strings.isNullOrEmpty(nextPageToken)) {
-   *       request = request.toBuilder().setPageToken(nextPageToken).build();
-   *     } else {
-   *       break;
-   *     }
-   *   }
+   *   ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
+   *   // Do something
+   *   Job response = future.get();
    * }
    * 
*/ - public final UnaryCallable listJobsCallable() { - return stub.listJobsCallable(); + public final UnaryCallable updateJobCallable() { + return stub.updateJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Gets a job. + * Deletes a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.getJob(name);
+   *   cloudSchedulerClient.deleteJob(name);
    * }
    * 
* @@ -620,22 +597,22 @@ public final UnaryCallable listJobsCallable() * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job getJob(JobName name) { - GetJobRequest request = - GetJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); - return getJob(request); + public final void deleteJob(JobName name) { + DeleteJobRequest request = + DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); + deleteJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Gets a job. + * Deletes a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   Job response = cloudSchedulerClient.getJob(name.toString());
+   *   cloudSchedulerClient.deleteJob(name.toString());
    * }
    * 
* @@ -643,259 +620,282 @@ public final Job getJob(JobName name) { * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job getJob(String name) { - GetJobRequest request = GetJobRequest.newBuilder().setName(name).build(); - return getJob(request); + public final void deleteJob(String name) { + DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build(); + deleteJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Gets a job. + * Deletes a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   GetJobRequest request = GetJobRequest.newBuilder()
+   *   DeleteJobRequest request = DeleteJobRequest.newBuilder()
    *     .setName(name.toString())
    *     .build();
-   *   Job response = cloudSchedulerClient.getJob(request);
+   *   cloudSchedulerClient.deleteJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job getJob(GetJobRequest request) { - return getJobCallable().call(request); + public final void deleteJob(DeleteJobRequest request) { + deleteJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Gets a job. + * Deletes a job. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
    *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-   *   GetJobRequest request = GetJobRequest.newBuilder()
+   *   DeleteJobRequest request = DeleteJobRequest.newBuilder()
    *     .setName(name.toString())
    *     .build();
-   *   ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
+   *   ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
    *   // Do something
-   *   Job response = future.get();
+   *   future.get();
    * }
    * 
*/ - public final UnaryCallable getJobCallable() { - return stub.getJobCallable(); + public final UnaryCallable deleteJobCallable() { + return stub.deleteJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Creates a job. + * Pauses a job. + * + *

If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   Job job = Job.newBuilder().build();
-   *   Job response = cloudSchedulerClient.createJob(parent, job);
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   Job response = cloudSchedulerClient.pauseJob(name);
    * }
    * 
* - * @param parent Required. The location name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID`. - * @param job Required. The job to add. The user can optionally specify a name for the job in - * [name][google.cloud.scheduler.v1beta1.Job.name]. - * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a - * name is not specified then the system will generate a random unique name that will be - * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response. + * @param name Required. The job name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job createJob(LocationName parent, Job job) { - CreateJobRequest request = - CreateJobRequest.newBuilder() - .setParent(parent == null ? null : parent.toString()) - .setJob(job) - .build(); - return createJob(request); + public final Job pauseJob(JobName name) { + PauseJobRequest request = + PauseJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); + return pauseJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Creates a job. + * Pauses a job. + * + *

If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   Job job = Job.newBuilder().build();
-   *   Job response = cloudSchedulerClient.createJob(parent.toString(), job);
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   Job response = cloudSchedulerClient.pauseJob(name.toString());
    * }
    * 
* - * @param parent Required. The location name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID`. - * @param job Required. The job to add. The user can optionally specify a name for the job in - * [name][google.cloud.scheduler.v1beta1.Job.name]. - * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a - * name is not specified then the system will generate a random unique name that will be - * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response. + * @param name Required. The job name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job createJob(String parent, Job job) { - CreateJobRequest request = CreateJobRequest.newBuilder().setParent(parent).setJob(job).build(); - return createJob(request); + public final Job pauseJob(String name) { + PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build(); + return pauseJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Creates a job. + * Pauses a job. + * + *

If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   Job job = Job.newBuilder().build();
-   *   CreateJobRequest request = CreateJobRequest.newBuilder()
-   *     .setParent(parent.toString())
-   *     .setJob(job)
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   PauseJobRequest request = PauseJobRequest.newBuilder()
+   *     .setName(name.toString())
    *     .build();
-   *   Job response = cloudSchedulerClient.createJob(request);
+   *   Job response = cloudSchedulerClient.pauseJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job createJob(CreateJobRequest request) { - return createJobCallable().call(request); + public final Job pauseJob(PauseJobRequest request) { + return pauseJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Creates a job. + * Pauses a job. + * + *

If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-   *   Job job = Job.newBuilder().build();
-   *   CreateJobRequest request = CreateJobRequest.newBuilder()
-   *     .setParent(parent.toString())
-   *     .setJob(job)
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   PauseJobRequest request = PauseJobRequest.newBuilder()
+   *     .setName(name.toString())
    *     .build();
-   *   ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
+   *   ApiFuture<Job> future = cloudSchedulerClient.pauseJobCallable().futureCall(request);
    *   // Do something
    *   Job response = future.get();
    * }
    * 
*/ - public final UnaryCallable createJobCallable() { - return stub.createJobCallable(); + public final UnaryCallable pauseJobCallable() { + return stub.pauseJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Updates a job. - * - *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + * Resume a job. * - *

If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *

This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   Job job = Job.newBuilder().build();
-   *   FieldMask updateMask = FieldMask.newBuilder().build();
-   *   Job response = cloudSchedulerClient.updateJob(job, updateMask);
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   Job response = cloudSchedulerClient.resumeJob(name);
    * }
    * 
* - * @param job Required. The new job properties. [name][google.cloud.scheduler.v1beta1.Job.name] - * must be specified. - *

Output only fields cannot be modified using UpdateJob. Any value specified for an output - * only field will be ignored. - * @param updateMask A mask used to specify which fields of the job are being updated. + * @param name Required. The job name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job updateJob(Job job, FieldMask updateMask) { - UpdateJobRequest request = - UpdateJobRequest.newBuilder().setJob(job).setUpdateMask(updateMask).build(); - return updateJob(request); + public final Job resumeJob(JobName name) { + ResumeJobRequest request = + ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); + return resumeJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Updates a job. + * Resume a job. * - *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + *

This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * - *

If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *

Sample code: + * + *


+   * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   Job response = cloudSchedulerClient.resumeJob(name.toString());
+   * }
+   * 
+ * + * @param name Required. The job name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. + * @throws com.google.api.gax.rpc.ApiException if the remote call fails + */ + public final Job resumeJob(String name) { + ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build(); + return resumeJob(request); + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD + /** + * Resume a job. + * + *

This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   Job job = Job.newBuilder().build();
-   *   UpdateJobRequest request = UpdateJobRequest.newBuilder()
-   *     .setJob(job)
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   ResumeJobRequest request = ResumeJobRequest.newBuilder()
+   *     .setName(name.toString())
    *     .build();
-   *   Job response = cloudSchedulerClient.updateJob(request);
+   *   Job response = cloudSchedulerClient.resumeJob(request);
    * }
    * 
* * @param request The request object containing all of the parameters for the API call. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job updateJob(UpdateJobRequest request) { - return updateJobCallable().call(request); + public final Job resumeJob(ResumeJobRequest request) { + return resumeJobCallable().call(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Updates a job. - * - *

If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + * Resume a job. * - *

If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *

This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *

Sample code: * *


    * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
-   *   Job job = Job.newBuilder().build();
-   *   UpdateJobRequest request = UpdateJobRequest.newBuilder()
-   *     .setJob(job)
+   *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+   *   ResumeJobRequest request = ResumeJobRequest.newBuilder()
+   *     .setName(name.toString())
    *     .build();
-   *   ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
+   *   ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
    *   // Do something
    *   Job response = future.get();
    * }
    * 
*/ - public final UnaryCallable updateJobCallable() { - return stub.updateJobCallable(); + public final UnaryCallable resumeJobCallable() { + return stub.resumeJobCallable(); } // AUTO-GENERATED DOCUMENTATION AND METHOD diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java index f017c69c..9404a99a 100644 --- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java +++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java @@ -50,16 +50,16 @@ *

The builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * - *

For example, to set the total timeout of deleteJob to 30 seconds: + *

For example, to set the total timeout of getJob to 30 seconds: * *

  * 
  * CloudSchedulerSettings.Builder cloudSchedulerSettingsBuilder =
  *     CloudSchedulerSettings.newBuilder();
  * cloudSchedulerSettingsBuilder
- *     .deleteJobSettings()
+ *     .getJobSettings()
  *     .setRetrySettings(
- *         cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
+ *         cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
  *             .setTotalTimeout(Duration.ofSeconds(30))
  *             .build());
  * CloudSchedulerSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -69,21 +69,6 @@
 @Generated("by gapic-generator")
 @BetaApi
 public class CloudSchedulerSettings extends ClientSettings {
-  /** Returns the object with the settings used for calls to deleteJob. */
-  public UnaryCallSettings deleteJobSettings() {
-    return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
-  }
-
-  /** Returns the object with the settings used for calls to pauseJob. */
-  public UnaryCallSettings pauseJobSettings() {
-    return ((CloudSchedulerStubSettings) getStubSettings()).pauseJobSettings();
-  }
-
-  /** Returns the object with the settings used for calls to resumeJob. */
-  public UnaryCallSettings resumeJobSettings() {
-    return ((CloudSchedulerStubSettings) getStubSettings()).resumeJobSettings();
-  }
-
   /** Returns the object with the settings used for calls to listJobs. */
   public PagedCallSettings
       listJobsSettings() {
@@ -105,6 +90,21 @@ public UnaryCallSettings updateJobSettings() {
     return ((CloudSchedulerStubSettings) getStubSettings()).updateJobSettings();
   }
 
+  /** Returns the object with the settings used for calls to deleteJob. */
+  public UnaryCallSettings deleteJobSettings() {
+    return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
+  }
+
+  /** Returns the object with the settings used for calls to pauseJob. */
+  public UnaryCallSettings pauseJobSettings() {
+    return ((CloudSchedulerStubSettings) getStubSettings()).pauseJobSettings();
+  }
+
+  /** Returns the object with the settings used for calls to resumeJob. */
+  public UnaryCallSettings resumeJobSettings() {
+    return ((CloudSchedulerStubSettings) getStubSettings()).resumeJobSettings();
+  }
+
   /** Returns the object with the settings used for calls to runJob. */
   public UnaryCallSettings runJobSettings() {
     return ((CloudSchedulerStubSettings) getStubSettings()).runJobSettings();
@@ -207,21 +207,6 @@ public Builder applyToAllUnaryMethods(
       return this;
     }
 
-    /** Returns the builder for the settings used for calls to deleteJob. */
-    public UnaryCallSettings.Builder deleteJobSettings() {
-      return getStubSettingsBuilder().deleteJobSettings();
-    }
-
-    /** Returns the builder for the settings used for calls to pauseJob. */
-    public UnaryCallSettings.Builder pauseJobSettings() {
-      return getStubSettingsBuilder().pauseJobSettings();
-    }
-
-    /** Returns the builder for the settings used for calls to resumeJob. */
-    public UnaryCallSettings.Builder resumeJobSettings() {
-      return getStubSettingsBuilder().resumeJobSettings();
-    }
-
     /** Returns the builder for the settings used for calls to listJobs. */
     public PagedCallSettings.Builder
         listJobsSettings() {
@@ -243,6 +228,21 @@ public UnaryCallSettings.Builder updateJobSettings() {
       return getStubSettingsBuilder().updateJobSettings();
     }
 
+    /** Returns the builder for the settings used for calls to deleteJob. */
+    public UnaryCallSettings.Builder deleteJobSettings() {
+      return getStubSettingsBuilder().deleteJobSettings();
+    }
+
+    /** Returns the builder for the settings used for calls to pauseJob. */
+    public UnaryCallSettings.Builder pauseJobSettings() {
+      return getStubSettingsBuilder().pauseJobSettings();
+    }
+
+    /** Returns the builder for the settings used for calls to resumeJob. */
+    public UnaryCallSettings.Builder resumeJobSettings() {
+      return getStubSettingsBuilder().resumeJobSettings();
+    }
+
     /** Returns the builder for the settings used for calls to runJob. */
     public UnaryCallSettings.Builder runJobSettings() {
       return getStubSettingsBuilder().runJobSettings();
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
index 6e112280..1765d197 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
@@ -30,7 +30,7 @@
  * 
  * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
  *   JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- *   cloudSchedulerClient.deleteJob(name);
+ *   Job response = cloudSchedulerClient.getJob(name);
  * }
  * 
  * 
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java index 2f15dee6..4231e22b 100644 --- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java +++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java @@ -43,18 +43,6 @@ @BetaApi("A restructuring of stub classes is planned, so this may break in the future") public abstract class CloudSchedulerStub implements BackgroundResource { - public UnaryCallable deleteJobCallable() { - throw new UnsupportedOperationException("Not implemented: deleteJobCallable()"); - } - - public UnaryCallable pauseJobCallable() { - throw new UnsupportedOperationException("Not implemented: pauseJobCallable()"); - } - - public UnaryCallable resumeJobCallable() { - throw new UnsupportedOperationException("Not implemented: resumeJobCallable()"); - } - public UnaryCallable listJobsPagedCallable() { throw new UnsupportedOperationException("Not implemented: listJobsPagedCallable()"); } @@ -75,6 +63,18 @@ public UnaryCallable updateJobCallable() { throw new UnsupportedOperationException("Not implemented: updateJobCallable()"); } + public UnaryCallable deleteJobCallable() { + throw new UnsupportedOperationException("Not implemented: deleteJobCallable()"); + } + + public UnaryCallable pauseJobCallable() { + throw new UnsupportedOperationException("Not implemented: pauseJobCallable()"); + } + + public UnaryCallable resumeJobCallable() { + throw new UnsupportedOperationException("Not implemented: resumeJobCallable()"); + } + public UnaryCallable runJobCallable() { throw new UnsupportedOperationException("Not implemented: runJobCallable()"); } diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java index ef24442f..8446f977 100644 --- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java +++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java @@ -75,16 +75,16 @@ *

The builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * - *

For example, to set the total timeout of deleteJob to 30 seconds: + *

For example, to set the total timeout of getJob to 30 seconds: * *

  * 
  * CloudSchedulerStubSettings.Builder cloudSchedulerSettingsBuilder =
  *     CloudSchedulerStubSettings.newBuilder();
  * cloudSchedulerSettingsBuilder
- *     .deleteJobSettings()
+ *     .getJobSettings()
  *     .setRetrySettings(
- *         cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
+ *         cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
  *             .setTotalTimeout(Duration.ofSeconds(30))
  *             .build());
  * CloudSchedulerStubSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -98,31 +98,16 @@ public class CloudSchedulerStubSettings extends StubSettings DEFAULT_SERVICE_SCOPES =
       ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
 
-  private final UnaryCallSettings deleteJobSettings;
-  private final UnaryCallSettings pauseJobSettings;
-  private final UnaryCallSettings resumeJobSettings;
   private final PagedCallSettings
       listJobsSettings;
   private final UnaryCallSettings getJobSettings;
   private final UnaryCallSettings createJobSettings;
   private final UnaryCallSettings updateJobSettings;
+  private final UnaryCallSettings deleteJobSettings;
+  private final UnaryCallSettings pauseJobSettings;
+  private final UnaryCallSettings resumeJobSettings;
   private final UnaryCallSettings runJobSettings;
 
-  /** Returns the object with the settings used for calls to deleteJob. */
-  public UnaryCallSettings deleteJobSettings() {
-    return deleteJobSettings;
-  }
-
-  /** Returns the object with the settings used for calls to pauseJob. */
-  public UnaryCallSettings pauseJobSettings() {
-    return pauseJobSettings;
-  }
-
-  /** Returns the object with the settings used for calls to resumeJob. */
-  public UnaryCallSettings resumeJobSettings() {
-    return resumeJobSettings;
-  }
-
   /** Returns the object with the settings used for calls to listJobs. */
   public PagedCallSettings
       listJobsSettings() {
@@ -144,6 +129,21 @@ public UnaryCallSettings updateJobSettings() {
     return updateJobSettings;
   }
 
+  /** Returns the object with the settings used for calls to deleteJob. */
+  public UnaryCallSettings deleteJobSettings() {
+    return deleteJobSettings;
+  }
+
+  /** Returns the object with the settings used for calls to pauseJob. */
+  public UnaryCallSettings pauseJobSettings() {
+    return pauseJobSettings;
+  }
+
+  /** Returns the object with the settings used for calls to resumeJob. */
+  public UnaryCallSettings resumeJobSettings() {
+    return resumeJobSettings;
+  }
+
   /** Returns the object with the settings used for calls to runJob. */
   public UnaryCallSettings runJobSettings() {
     return runJobSettings;
@@ -218,13 +218,13 @@ public Builder toBuilder() {
   protected CloudSchedulerStubSettings(Builder settingsBuilder) throws IOException {
     super(settingsBuilder);
 
-    deleteJobSettings = settingsBuilder.deleteJobSettings().build();
-    pauseJobSettings = settingsBuilder.pauseJobSettings().build();
-    resumeJobSettings = settingsBuilder.resumeJobSettings().build();
     listJobsSettings = settingsBuilder.listJobsSettings().build();
     getJobSettings = settingsBuilder.getJobSettings().build();
     createJobSettings = settingsBuilder.createJobSettings().build();
     updateJobSettings = settingsBuilder.updateJobSettings().build();
+    deleteJobSettings = settingsBuilder.deleteJobSettings().build();
+    pauseJobSettings = settingsBuilder.pauseJobSettings().build();
+    resumeJobSettings = settingsBuilder.resumeJobSettings().build();
     runJobSettings = settingsBuilder.runJobSettings().build();
   }
 
@@ -284,15 +284,15 @@ public ApiFuture getFuturePagedResponse(
   public static class Builder extends StubSettings.Builder {
     private final ImmutableList> unaryMethodSettingsBuilders;
 
-    private final UnaryCallSettings.Builder deleteJobSettings;
-    private final UnaryCallSettings.Builder pauseJobSettings;
-    private final UnaryCallSettings.Builder resumeJobSettings;
     private final PagedCallSettings.Builder<
             ListJobsRequest, ListJobsResponse, ListJobsPagedResponse>
         listJobsSettings;
     private final UnaryCallSettings.Builder getJobSettings;
     private final UnaryCallSettings.Builder createJobSettings;
     private final UnaryCallSettings.Builder updateJobSettings;
+    private final UnaryCallSettings.Builder deleteJobSettings;
+    private final UnaryCallSettings.Builder pauseJobSettings;
+    private final UnaryCallSettings.Builder resumeJobSettings;
     private final UnaryCallSettings.Builder runJobSettings;
 
     private static final ImmutableMap>
@@ -302,11 +302,13 @@ public static class Builder extends StubSettings.Builder> definitions =
           ImmutableMap.builder();
       definitions.put(
-          "idempotent",
+          "retry_policy_1_codes",
           ImmutableSet.copyOf(
               Lists.newArrayList(
                   StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
-      definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.newArrayList()));
+      definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+      definitions.put(
+          "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
       RETRYABLE_CODE_DEFINITIONS = definitions.build();
     }
 
@@ -320,12 +322,22 @@ public static class Builder extends StubSettings.Builder>of(
-              deleteJobSettings,
-              pauseJobSettings,
-              resumeJobSettings,
               listJobsSettings,
               getJobSettings,
               createJobSettings,
               updateJobSettings,
+              deleteJobSettings,
+              pauseJobSettings,
+              resumeJobSettings,
               runJobSettings);
 
       initDefaults(this);
@@ -378,44 +390,44 @@ private static Builder createDefault() {
     private static Builder initDefaults(Builder builder) {
 
       builder
-          .deleteJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .listJobsSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
 
       builder
-          .pauseJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .getJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
 
       builder
-          .resumeJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .createJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
 
       builder
-          .listJobsSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .updateJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
 
       builder
-          .getJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .deleteJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
 
       builder
-          .createJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .pauseJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
 
       builder
-          .updateJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .resumeJobSettings()
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
 
       builder
           .runJobSettings()
-          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
-          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+          .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+          .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
 
       return builder;
     }
@@ -423,24 +435,24 @@ private static Builder initDefaults(Builder builder) {
     protected Builder(CloudSchedulerStubSettings settings) {
       super(settings);
 
-      deleteJobSettings = settings.deleteJobSettings.toBuilder();
-      pauseJobSettings = settings.pauseJobSettings.toBuilder();
-      resumeJobSettings = settings.resumeJobSettings.toBuilder();
       listJobsSettings = settings.listJobsSettings.toBuilder();
       getJobSettings = settings.getJobSettings.toBuilder();
       createJobSettings = settings.createJobSettings.toBuilder();
       updateJobSettings = settings.updateJobSettings.toBuilder();
+      deleteJobSettings = settings.deleteJobSettings.toBuilder();
+      pauseJobSettings = settings.pauseJobSettings.toBuilder();
+      resumeJobSettings = settings.resumeJobSettings.toBuilder();
       runJobSettings = settings.runJobSettings.toBuilder();
 
       unaryMethodSettingsBuilders =
           ImmutableList.>of(
-              deleteJobSettings,
-              pauseJobSettings,
-              resumeJobSettings,
               listJobsSettings,
               getJobSettings,
               createJobSettings,
               updateJobSettings,
+              deleteJobSettings,
+              pauseJobSettings,
+              resumeJobSettings,
               runJobSettings);
     }
 
@@ -460,21 +472,6 @@ public Builder applyToAllUnaryMethods(
       return unaryMethodSettingsBuilders;
     }
 
-    /** Returns the builder for the settings used for calls to deleteJob. */
-    public UnaryCallSettings.Builder deleteJobSettings() {
-      return deleteJobSettings;
-    }
-
-    /** Returns the builder for the settings used for calls to pauseJob. */
-    public UnaryCallSettings.Builder pauseJobSettings() {
-      return pauseJobSettings;
-    }
-
-    /** Returns the builder for the settings used for calls to resumeJob. */
-    public UnaryCallSettings.Builder resumeJobSettings() {
-      return resumeJobSettings;
-    }
-
     /** Returns the builder for the settings used for calls to listJobs. */
     public PagedCallSettings.Builder
         listJobsSettings() {
@@ -496,6 +493,21 @@ public UnaryCallSettings.Builder updateJobSettings() {
       return updateJobSettings;
     }
 
+    /** Returns the builder for the settings used for calls to deleteJob. */
+    public UnaryCallSettings.Builder deleteJobSettings() {
+      return deleteJobSettings;
+    }
+
+    /** Returns the builder for the settings used for calls to pauseJob. */
+    public UnaryCallSettings.Builder pauseJobSettings() {
+      return pauseJobSettings;
+    }
+
+    /** Returns the builder for the settings used for calls to resumeJob. */
+    public UnaryCallSettings.Builder resumeJobSettings() {
+      return resumeJobSettings;
+    }
+
     /** Returns the builder for the settings used for calls to runJob. */
     public UnaryCallSettings.Builder runJobSettings() {
       return runJobSettings;
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
index dca1ad7f..c50bb2ed 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
@@ -54,27 +54,6 @@
 @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
 public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
 
-  private static final MethodDescriptor deleteJobMethodDescriptor =
-      MethodDescriptor.newBuilder()
-          .setType(MethodDescriptor.MethodType.UNARY)
-          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob")
-          .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
-          .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
-          .build();
-  private static final MethodDescriptor pauseJobMethodDescriptor =
-      MethodDescriptor.newBuilder()
-          .setType(MethodDescriptor.MethodType.UNARY)
-          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob")
-          .setRequestMarshaller(ProtoUtils.marshaller(PauseJobRequest.getDefaultInstance()))
-          .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
-          .build();
-  private static final MethodDescriptor resumeJobMethodDescriptor =
-      MethodDescriptor.newBuilder()
-          .setType(MethodDescriptor.MethodType.UNARY)
-          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob")
-          .setRequestMarshaller(ProtoUtils.marshaller(ResumeJobRequest.getDefaultInstance()))
-          .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
-          .build();
   private static final MethodDescriptor
       listJobsMethodDescriptor =
           MethodDescriptor.newBuilder()
@@ -104,6 +83,27 @@ public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
           .setRequestMarshaller(ProtoUtils.marshaller(UpdateJobRequest.getDefaultInstance()))
           .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
           .build();
+  private static final MethodDescriptor deleteJobMethodDescriptor =
+      MethodDescriptor.newBuilder()
+          .setType(MethodDescriptor.MethodType.UNARY)
+          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob")
+          .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
+          .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+          .build();
+  private static final MethodDescriptor pauseJobMethodDescriptor =
+      MethodDescriptor.newBuilder()
+          .setType(MethodDescriptor.MethodType.UNARY)
+          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob")
+          .setRequestMarshaller(ProtoUtils.marshaller(PauseJobRequest.getDefaultInstance()))
+          .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
+          .build();
+  private static final MethodDescriptor resumeJobMethodDescriptor =
+      MethodDescriptor.newBuilder()
+          .setType(MethodDescriptor.MethodType.UNARY)
+          .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob")
+          .setRequestMarshaller(ProtoUtils.marshaller(ResumeJobRequest.getDefaultInstance()))
+          .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
+          .build();
   private static final MethodDescriptor runJobMethodDescriptor =
       MethodDescriptor.newBuilder()
           .setType(MethodDescriptor.MethodType.UNARY)
@@ -114,14 +114,14 @@ public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
 
   private final BackgroundResource backgroundResources;
 
-  private final UnaryCallable deleteJobCallable;
-  private final UnaryCallable pauseJobCallable;
-  private final UnaryCallable resumeJobCallable;
   private final UnaryCallable listJobsCallable;
   private final UnaryCallable listJobsPagedCallable;
   private final UnaryCallable getJobCallable;
   private final UnaryCallable createJobCallable;
   private final UnaryCallable updateJobCallable;
+  private final UnaryCallable deleteJobCallable;
+  private final UnaryCallable pauseJobCallable;
+  private final UnaryCallable resumeJobCallable;
   private final UnaryCallable runJobCallable;
 
   private final GrpcStubCallableFactory callableFactory;
@@ -165,45 +165,6 @@ protected GrpcCloudSchedulerStub(
       throws IOException {
     this.callableFactory = callableFactory;
 
-    GrpcCallSettings deleteJobTransportSettings =
-        GrpcCallSettings.newBuilder()
-            .setMethodDescriptor(deleteJobMethodDescriptor)
-            .setParamsExtractor(
-                new RequestParamsExtractor() {
-                  @Override
-                  public Map extract(DeleteJobRequest request) {
-                    ImmutableMap.Builder params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
-                })
-            .build();
-    GrpcCallSettings pauseJobTransportSettings =
-        GrpcCallSettings.newBuilder()
-            .setMethodDescriptor(pauseJobMethodDescriptor)
-            .setParamsExtractor(
-                new RequestParamsExtractor() {
-                  @Override
-                  public Map extract(PauseJobRequest request) {
-                    ImmutableMap.Builder params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
-                })
-            .build();
-    GrpcCallSettings resumeJobTransportSettings =
-        GrpcCallSettings.newBuilder()
-            .setMethodDescriptor(resumeJobMethodDescriptor)
-            .setParamsExtractor(
-                new RequestParamsExtractor() {
-                  @Override
-                  public Map extract(ResumeJobRequest request) {
-                    ImmutableMap.Builder params = ImmutableMap.builder();
-                    params.put("name", String.valueOf(request.getName()));
-                    return params.build();
-                  }
-                })
-            .build();
     GrpcCallSettings listJobsTransportSettings =
         GrpcCallSettings.newBuilder()
             .setMethodDescriptor(listJobsMethodDescriptor)
@@ -256,6 +217,45 @@ public Map extract(UpdateJobRequest request) {
                   }
                 })
             .build();
+    GrpcCallSettings deleteJobTransportSettings =
+        GrpcCallSettings.newBuilder()
+            .setMethodDescriptor(deleteJobMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor() {
+                  @Override
+                  public Map extract(DeleteJobRequest request) {
+                    ImmutableMap.Builder params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
+            .build();
+    GrpcCallSettings pauseJobTransportSettings =
+        GrpcCallSettings.newBuilder()
+            .setMethodDescriptor(pauseJobMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor() {
+                  @Override
+                  public Map extract(PauseJobRequest request) {
+                    ImmutableMap.Builder params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
+            .build();
+    GrpcCallSettings resumeJobTransportSettings =
+        GrpcCallSettings.newBuilder()
+            .setMethodDescriptor(resumeJobMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor() {
+                  @Override
+                  public Map extract(ResumeJobRequest request) {
+                    ImmutableMap.Builder params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
+            .build();
     GrpcCallSettings runJobTransportSettings =
         GrpcCallSettings.newBuilder()
             .setMethodDescriptor(runJobMethodDescriptor)
@@ -270,15 +270,6 @@ public Map extract(RunJobRequest request) {
                 })
             .build();
 
-    this.deleteJobCallable =
-        callableFactory.createUnaryCallable(
-            deleteJobTransportSettings, settings.deleteJobSettings(), clientContext);
-    this.pauseJobCallable =
-        callableFactory.createUnaryCallable(
-            pauseJobTransportSettings, settings.pauseJobSettings(), clientContext);
-    this.resumeJobCallable =
-        callableFactory.createUnaryCallable(
-            resumeJobTransportSettings, settings.resumeJobSettings(), clientContext);
     this.listJobsCallable =
         callableFactory.createUnaryCallable(
             listJobsTransportSettings, settings.listJobsSettings(), clientContext);
@@ -294,6 +285,15 @@ public Map extract(RunJobRequest request) {
     this.updateJobCallable =
         callableFactory.createUnaryCallable(
             updateJobTransportSettings, settings.updateJobSettings(), clientContext);
+    this.deleteJobCallable =
+        callableFactory.createUnaryCallable(
+            deleteJobTransportSettings, settings.deleteJobSettings(), clientContext);
+    this.pauseJobCallable =
+        callableFactory.createUnaryCallable(
+            pauseJobTransportSettings, settings.pauseJobSettings(), clientContext);
+    this.resumeJobCallable =
+        callableFactory.createUnaryCallable(
+            resumeJobTransportSettings, settings.resumeJobSettings(), clientContext);
     this.runJobCallable =
         callableFactory.createUnaryCallable(
             runJobTransportSettings, settings.runJobSettings(), clientContext);
@@ -301,18 +301,6 @@ public Map extract(RunJobRequest request) {
     backgroundResources = new BackgroundResourceAggregation(clientContext.getBackgroundResources());
   }
 
-  public UnaryCallable deleteJobCallable() {
-    return deleteJobCallable;
-  }
-
-  public UnaryCallable pauseJobCallable() {
-    return pauseJobCallable;
-  }
-
-  public UnaryCallable resumeJobCallable() {
-    return resumeJobCallable;
-  }
-
   public UnaryCallable listJobsPagedCallable() {
     return listJobsPagedCallable;
   }
@@ -333,6 +321,18 @@ public UnaryCallable updateJobCallable() {
     return updateJobCallable;
   }
 
+  public UnaryCallable deleteJobCallable() {
+    return deleteJobCallable;
+  }
+
+  public UnaryCallable pauseJobCallable() {
+    return pauseJobCallable;
+  }
+
+  public UnaryCallable resumeJobCallable() {
+    return resumeJobCallable;
+  }
+
   public UnaryCallable runJobCallable() {
     return runJobCallable;
   }
diff --git a/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
index 7e471a2f..2c6b9855 100644
--- a/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
+++ b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
@@ -81,19 +81,27 @@ public void tearDown() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void deleteJobTest() {
-    Empty expectedResponse = Empty.newBuilder().build();
+  public void listJobsTest() {
+    String nextPageToken = "";
+    Job jobsElement = Job.newBuilder().build();
+    List jobs = Arrays.asList(jobsElement);
+    ListJobsResponse expectedResponse =
+        ListJobsResponse.newBuilder().setNextPageToken(nextPageToken).addAllJobs(jobs).build();
     mockCloudScheduler.addResponse(expectedResponse);
 
-    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+    LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
 
-    client.deleteJob(name);
+    ListJobsPagedResponse pagedListResponse = client.listJobs(parent);
+
+    List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+    Assert.assertEquals(1, resources.size());
+    Assert.assertEquals(expectedResponse.getJobsList().get(0), resources.get(0));
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
+    ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
 
-    Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+    Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -102,14 +110,14 @@ public void deleteJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void deleteJobExceptionTest() throws Exception {
+  public void listJobsExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
-      JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+      LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
 
-      client.deleteJob(name);
+      client.listJobs(parent);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -118,7 +126,7 @@ public void deleteJobExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void pauseJobTest() {
+  public void getJobTest() {
     JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
     String description = "description-1724546052";
     String schedule = "schedule-697920873";
@@ -134,12 +142,12 @@ public void pauseJobTest() {
 
     JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-    Job actualResponse = client.pauseJob(name);
+    Job actualResponse = client.getJob(name);
     Assert.assertEquals(expectedResponse, actualResponse);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    PauseJobRequest actualRequest = (PauseJobRequest) actualRequests.get(0);
+    GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
 
     Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
     Assert.assertTrue(
@@ -150,14 +158,14 @@ public void pauseJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void pauseJobExceptionTest() throws Exception {
+  public void getJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
       JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-      client.pauseJob(name);
+      client.getJob(name);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -166,30 +174,32 @@ public void pauseJobExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void resumeJobTest() {
-    JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+  public void createJobTest() {
+    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
     String description = "description-1724546052";
     String schedule = "schedule-697920873";
     String timeZone = "timeZone36848094";
     Job expectedResponse =
         Job.newBuilder()
-            .setName(name2.toString())
+            .setName(name.toString())
             .setDescription(description)
             .setSchedule(schedule)
             .setTimeZone(timeZone)
             .build();
     mockCloudScheduler.addResponse(expectedResponse);
 
-    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+    LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+    Job job = Job.newBuilder().build();
 
-    Job actualResponse = client.resumeJob(name);
+    Job actualResponse = client.createJob(parent, job);
     Assert.assertEquals(expectedResponse, actualResponse);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    ResumeJobRequest actualRequest = (ResumeJobRequest) actualRequests.get(0);
+    CreateJobRequest actualRequest = (CreateJobRequest) actualRequests.get(0);
 
-    Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+    Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
+    Assert.assertEquals(job, actualRequest.getJob());
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -198,14 +208,15 @@ public void resumeJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void resumeJobExceptionTest() throws Exception {
+  public void createJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
-      JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+      LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+      Job job = Job.newBuilder().build();
 
-      client.resumeJob(name);
+      client.createJob(parent, job);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -214,27 +225,32 @@ public void resumeJobExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void listJobsTest() {
-    String nextPageToken = "";
-    Job jobsElement = Job.newBuilder().build();
-    List jobs = Arrays.asList(jobsElement);
-    ListJobsResponse expectedResponse =
-        ListJobsResponse.newBuilder().setNextPageToken(nextPageToken).addAllJobs(jobs).build();
+  public void updateJobTest() {
+    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+    String description = "description-1724546052";
+    String schedule = "schedule-697920873";
+    String timeZone = "timeZone36848094";
+    Job expectedResponse =
+        Job.newBuilder()
+            .setName(name.toString())
+            .setDescription(description)
+            .setSchedule(schedule)
+            .setTimeZone(timeZone)
+            .build();
     mockCloudScheduler.addResponse(expectedResponse);
 
-    LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-
-    ListJobsPagedResponse pagedListResponse = client.listJobs(parent);
+    Job job = Job.newBuilder().build();
+    FieldMask updateMask = FieldMask.newBuilder().build();
 
-    List resources = Lists.newArrayList(pagedListResponse.iterateAll());
-    Assert.assertEquals(1, resources.size());
-    Assert.assertEquals(expectedResponse.getJobsList().get(0), resources.get(0));
+    Job actualResponse = client.updateJob(job, updateMask);
+    Assert.assertEquals(expectedResponse, actualResponse);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
+    UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
 
-    Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
+    Assert.assertEquals(job, actualRequest.getJob());
+    Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -243,14 +259,15 @@ public void listJobsTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void listJobsExceptionTest() throws Exception {
+  public void updateJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
-      LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+      Job job = Job.newBuilder().build();
+      FieldMask updateMask = FieldMask.newBuilder().build();
 
-      client.listJobs(parent);
+      client.updateJob(job, updateMask);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -259,28 +276,17 @@ public void listJobsExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void getJobTest() {
-    JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-    String description = "description-1724546052";
-    String schedule = "schedule-697920873";
-    String timeZone = "timeZone36848094";
-    Job expectedResponse =
-        Job.newBuilder()
-            .setName(name2.toString())
-            .setDescription(description)
-            .setSchedule(schedule)
-            .setTimeZone(timeZone)
-            .build();
+  public void deleteJobTest() {
+    Empty expectedResponse = Empty.newBuilder().build();
     mockCloudScheduler.addResponse(expectedResponse);
 
     JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-    Job actualResponse = client.getJob(name);
-    Assert.assertEquals(expectedResponse, actualResponse);
+    client.deleteJob(name);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
+    DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
 
     Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
     Assert.assertTrue(
@@ -291,14 +297,14 @@ public void getJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void getJobExceptionTest() throws Exception {
+  public void deleteJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
       JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-      client.getJob(name);
+      client.deleteJob(name);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -307,32 +313,30 @@ public void getJobExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void createJobTest() {
-    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+  public void pauseJobTest() {
+    JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
     String description = "description-1724546052";
     String schedule = "schedule-697920873";
     String timeZone = "timeZone36848094";
     Job expectedResponse =
         Job.newBuilder()
-            .setName(name.toString())
+            .setName(name2.toString())
             .setDescription(description)
             .setSchedule(schedule)
             .setTimeZone(timeZone)
             .build();
     mockCloudScheduler.addResponse(expectedResponse);
 
-    LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-    Job job = Job.newBuilder().build();
+    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-    Job actualResponse = client.createJob(parent, job);
+    Job actualResponse = client.pauseJob(name);
     Assert.assertEquals(expectedResponse, actualResponse);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    CreateJobRequest actualRequest = (CreateJobRequest) actualRequests.get(0);
+    PauseJobRequest actualRequest = (PauseJobRequest) actualRequests.get(0);
 
-    Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
-    Assert.assertEquals(job, actualRequest.getJob());
+    Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -341,15 +345,14 @@ public void createJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void createJobExceptionTest() throws Exception {
+  public void pauseJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
-      LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-      Job job = Job.newBuilder().build();
+      JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-      client.createJob(parent, job);
+      client.pauseJob(name);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
@@ -358,32 +361,30 @@ public void createJobExceptionTest() throws Exception {
 
   @Test
   @SuppressWarnings("all")
-  public void updateJobTest() {
-    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+  public void resumeJobTest() {
+    JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
     String description = "description-1724546052";
     String schedule = "schedule-697920873";
     String timeZone = "timeZone36848094";
     Job expectedResponse =
         Job.newBuilder()
-            .setName(name.toString())
+            .setName(name2.toString())
             .setDescription(description)
             .setSchedule(schedule)
             .setTimeZone(timeZone)
             .build();
     mockCloudScheduler.addResponse(expectedResponse);
 
-    Job job = Job.newBuilder().build();
-    FieldMask updateMask = FieldMask.newBuilder().build();
+    JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-    Job actualResponse = client.updateJob(job, updateMask);
+    Job actualResponse = client.resumeJob(name);
     Assert.assertEquals(expectedResponse, actualResponse);
 
     List actualRequests = mockCloudScheduler.getRequests();
     Assert.assertEquals(1, actualRequests.size());
-    UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
+    ResumeJobRequest actualRequest = (ResumeJobRequest) actualRequests.get(0);
 
-    Assert.assertEquals(job, actualRequest.getJob());
-    Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
+    Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -392,15 +393,14 @@ public void updateJobTest() {
 
   @Test
   @SuppressWarnings("all")
-  public void updateJobExceptionTest() throws Exception {
+  public void resumeJobExceptionTest() throws Exception {
     StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
     mockCloudScheduler.addException(exception);
 
     try {
-      Job job = Job.newBuilder().build();
-      FieldMask updateMask = FieldMask.newBuilder().build();
+      JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
 
-      client.updateJob(job, updateMask);
+      client.resumeJob(name);
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       // Expected exception
diff --git a/synth.metadata b/synth.metadata
index 5685e8de..0cc9ed4d 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,15 +4,15 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-scheduler.git",
-        "sha": "a577b9c9bb6348f65477b7ac575c5f262dbf13b4"
+        "sha": "c0cc92c78c7068622e1c59793beb792f586e7fa2"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "c4e37010d74071851ff24121f522e802231ac86e",
-        "internalRef": "313460921"
+        "sha": "88ee692c9acb9b40bfd44a34fece543d472d2182",
+        "internalRef": "316713534"
       }
     },
     {