locking now checks lock folder exists in s3

dist/index.js

@@ -3073,16 +3073,18 @@ class Kubernetes {
     }
     createNamespacedJob(commands, image, mountdir, workingdir, environment, secrets) {
         return __awaiter(this, void 0, void 0, function* () {
+            for (let index = 0; index < 3; index++) {
                 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');
+                    return;
                 }
                 catch (error) {
                     cloud_runner_logger_1.default.log(`Error occured creating job: ${error}`);
-                throw error;
+                }
             }
         });
     }

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

@@ -162,6 +162,7 @@ class Kubernetes implements ProviderInterface {
     environment: CloudRunnerEnvironmentVariable[],
     secrets: CloudRunnerSecret[],
   ) {
+    for (let index = 0; index < 3; index++) {
       try {
         const jobSpec = KubernetesJobSpecFactory.getJobSpec(
           commands,
@@ -181,9 +182,11 @@ class Kubernetes implements ProviderInterface {
         CloudRunnerLogger.log(`Build job created`);
         await new Promise((promise) => setTimeout(promise, 5000));
         CloudRunnerLogger.log('Job created');
+
+        return;
       } catch (error) {
         CloudRunnerLogger.log(`Error occured creating job: ${error}`);
-      throw error;
+      }
     }
   }