Error Management catch known errors [GCSBucketDelete]

Author: psainics

src/main/java/io/cdap/plugin/gcp/gcs/actions/GCSBucketDelete.java

@@ -25,6 +25,9 @@
 import io.cdap.cdap.api.annotation.Macro;
 import io.cdap.cdap.api.annotation.Name;
 import io.cdap.cdap.api.annotation.Plugin;
+import io.cdap.cdap.api.exception.ErrorCategory;
+import io.cdap.cdap.api.exception.ErrorType;
+import io.cdap.cdap.api.exception.ErrorUtils;
 import io.cdap.cdap.etl.api.FailureCollector;
 import io.cdap.cdap.etl.api.PipelineConfigurer;
 import io.cdap.cdap.etl.api.action.Action;
@@ -76,8 +79,16 @@ public void run(ActionContext context) throws Exception {
       return;
     }
     String serviceAccount = config.getServiceAccount();
-    Credentials credentials = serviceAccount == null ?
-      null : GCPUtils.loadServiceAccountCredentials(serviceAccount, isServiceAccountFilePath);
+    Credentials credentials = null;
+    try {
+      credentials = serviceAccount == null ? null : GCPUtils.loadServiceAccountCredentials(serviceAccount,
+        isServiceAccountFilePath);
+    } catch (IOException e) {
+      String errorReason = "Failed to load service account credentials. ";
+      context.getFailureCollector().addFailure(String.format("%s %s", errorReason, e.getMessage()), null)
+        .withStacktrace(e.getStackTrace());
+      context.getFailureCollector().getOrThrowException();
+    }
     Map<String, String> map = GCPUtils.generateGCSAuthProperties(serviceAccount, config.getServiceAccountType());
     map.forEach(configuration::set);
     configuration.set("fs.gs.impl", "com.google.cloud.hadoop.fs.gcs.GoogleHadoopFileSystem");
@@ -99,9 +110,11 @@ public void run(ActionContext context) throws Exception {
         storage.get(gcsPath.getBucket());
       } catch (StorageException e) {
         // Add more descriptive error message
-        throw new RuntimeException(
-          String.format("Unable to access or create bucket %s. ", gcsPath.getBucket())
-            + "Ensure you entered the correct bucket path and have permissions for it.", e);
+        String errorReason = String.format("Unable to access or create bucket %s. ", gcsPath.getBucket()) +
+          "Ensure you entered the correct bucket path and have permissions for it.";
+        String errorMessage = String.format("%s %s", errorReason, e.getMessage());
+        throw ErrorUtils.getProgramFailureException(new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN),
+          errorReason, errorMessage, ErrorType.USER, true, e);
       }
       String exactGCSPath = "gs://" + gcsPath.getBucket() + "/" + gcsPath.getName();
       if (exactGCSPath.contains("*")) {