Fixed code

Author: TetyanaYahodska

compute/cloud-client/src/main/java/compute/disks/CreateDiskSecondaryRegional.java

@@ -56,9 +56,9 @@ public static void main(String[] args)
   }
 
   // Creates a secondary disk in a specified region.
-  public static Disk createDiskSecondaryRegional(String projectId, String secondaryProjectId,
-       String primaryDiskName, String secondaryDiskName, String primaryDiskRegion,
-       String secondaryDiskRegion, int diskSizeGb)
+  public static Operation.Status createDiskSecondaryRegional(String projectId,
+       String secondaryProjectId, String primaryDiskName, String secondaryDiskName,
+       String primaryDiskRegion, String secondaryDiskRegion, int diskSizeGb)
         throws IOException, ExecutionException, InterruptedException, TimeoutException {
     // An iterable collection of zone names in which you want to keep
     // the new disks' replicas. One of the replica zones of the clone must match
@@ -95,10 +95,9 @@ public static Disk createDiskSecondaryRegional(String projectId, String secondar
           .get(3, TimeUnit.MINUTES);
 
       if (response.hasError()) {
-        System.out.printf("Error creating disk: %s%n", response.getError());
-        return null;
+        throw new Error("Error creating disk! " + response.getError());
       }
-      return disksClient.get(secondaryProjectId, secondaryDiskRegion, secondaryDiskName);
+      return response.getStatus();
     }
   }
 }

compute/cloud-client/src/main/java/compute/disks/StartDiskReplication.java

@@ -78,8 +78,7 @@ public static Operation.Status startDiskAsyncReplication(String primaryProjectId
               primaryProjectId, primaryDiskLocation, primaryDiskName, replicationRequest).get();
 
       if (response.hasError()) {
-        System.out.printf("Error starting disk replication: %s%n", response.getError());
-        return null;
+        throw new Error("Error starting disk replication! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/StopDiskReplication.java

@@ -54,8 +54,7 @@ public static Operation.Status stopDiskAsyncReplication(
               project, diskLocation, diskName).get();
 
       if (response.hasError()) {
-        System.out.printf("Error stopping disk replication: %s%n", response.getError());
-        return null;
+        throw new Error("Error stopping disk replication! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/consistencygroup/AddDiskToConsistencyGroup.java

@@ -84,8 +84,7 @@ public static Operation.Status addDiskToConsistencyGroup(
 
       Operation response = disksClient.addResourcePoliciesAsync(disksRequest).get();
       if (response.hasError()) {
-        System.out.printf("Error adding disk to consistency group: %s%n", response.getError());
-        return null;
+        throw new Error("Error adding disk to consistency group! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/consistencygroup/CloneDisksFromConsistencyGroup.java

@@ -74,8 +74,7 @@ public static Operation.Status cloneDisksFromConsistencyGroup(String project,
       Operation response = disksClient.bulkInsertAsync(request).get(3, TimeUnit.MINUTES);
 
       if (response.hasError()) {
-        System.out.printf("Error cloning disks: %s%n", response.getError());
-        return null;
+        throw new Error("Error cloning disks! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/consistencygroup/CreateDiskConsistencyGroup.java

@@ -58,8 +58,7 @@ public static Operation.Status createDiskConsistencyGroup(
           regionResourcePoliciesClient.insertAsync(project, region, resourcePolicy).get();
 
       if (response.hasError()) {
-        System.out.printf("Error creating consistency group: %s%n", response.getError());
-        return null;
+        throw new Error("Error creating consistency group! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/consistencygroup/DeleteDiskConsistencyGroup.java

@@ -48,8 +48,7 @@ public static Operation.Status deleteDiskConsistencyGroup(
           .deleteAsync(project, region, consistencyGroupName).get();
 
       if (response.hasError()) {
-        System.out.printf("Error deleting disk: %s%n", response.getError());
-        return null;
+        throw new Error("Error deleting disk! " + response.getError());
       }
       return response.getStatus();
     }

compute/cloud-client/src/main/java/compute/disks/consistencygroup/RemoveDiskFromConsistencyGroup.java

@@ -85,8 +85,7 @@ public static Operation.Status removeDiskFromConsistencyGroup(
 
       Operation response = disksClient.removeResourcePoliciesAsync(disksRequest).get();
       if (response.hasError()) {
-        System.out.printf("Error removing disk from consistency group: %s%n", response.getError());
-        return null;
+        throw new Error("Error removing disk from consistency group! " + response.getError());
       }
       return response.getStatus();
     }