error handling for aws

dist/index.js

@@ -3073,11 +3073,17 @@ class Kubernetes {
     }
     createNamespacedJob(commands, image, mountdir, workingdir, environment, secrets) {
         return __awaiter(this, void 0, void 0, function* () {
+            try {
                 const jobSpec = kubernetes_job_spec_factory_1.default.getJobSpec(commands, image, mountdir, workingdir, environment, secrets, this.buildGuid, this.buildParameters, this.secretName, this.pvcName, this.jobName, k8s);
                 yield this.kubeClientBatch.createNamespacedJob(this.namespace, jobSpec);
                 cloud_runner_logger_1.default.log(`Build job created`);
                 yield new Promise((promise) => setTimeout(promise, 5000));
                 cloud_runner_logger_1.default.log('Job created');
+            }
+            catch (error) {
+                cloud_runner_logger_1.default.log(`Error occured creating job: ${error}`);
+                throw error;
+            }
         });
     }
     setPodNameAndContainerName(pod) {

src/model/cloud-runner/providers/k8s/index.ts

@@ -162,6 +162,7 @@ class Kubernetes implements ProviderInterface {
     environment: CloudRunnerEnvironmentVariable[],
     secrets: CloudRunnerSecret[],
   ) {
+    try {
       const jobSpec = KubernetesJobSpecFactory.getJobSpec(
         commands,
         image,
@@ -180,6 +181,10 @@ class Kubernetes implements ProviderInterface {
       CloudRunnerLogger.log(`Build job created`);
       await new Promise((promise) => setTimeout(promise, 5000));
       CloudRunnerLogger.log('Job created');
+    } catch (error) {
+      CloudRunnerLogger.log(`Error occured creating job: ${error}`);
+      throw error;
+    }
   }
 
   setPodNameAndContainerName(pod: k8s.V1Pod) {