recreate job

ppgia-unifor · Jul 29, 2024 · d305fca · d305fca
1 parent cd4fd7d
commit d305fca
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/resilience-bench/operator/src/main/java/io/resiliencebench/execution/ScenarioExecutor.java b/resilience-bench/operator/src/main/java/io/resiliencebench/execution/ScenarioExecutor.java
@@ -90,7 +90,12 @@ private Job createLoadGenerationJob(Scenario scenario, ExecutionQueue executionQ
 
   private void runJob(Job job) {
     var jobsClient = kubernetesClient.batch().v1().jobs();
-    job = jobsClient.resource(job).create();
+    var createdJob =
+            jobsClient.inNamespace(job.getMetadata().getNamespace()).withName(job.getMetadata().getName()).get();
+    if (createdJob != null) {
+      jobsClient.resource(createdJob).delete();
+    }
+    jobsClient.resource(job).create();
     jobsClient.resource(job).watch(this);
     logger.info("Job created: {}", job.getMetadata().getName());
   }
@@ -106,7 +111,6 @@ private void runScenario(String namespace, String scenarioName, ExecutionQueue e
       runPreparationSteps(scenario.get(), executionQueue);
       var job = createLoadGenerationJob(scenario.get(), executionQueue);
       runJob(job);
-      logger.info("Job created: {}", job.getMetadata().getName());
     } else {
       throw new RuntimeException(format("Scenario not found: %s.%s", namespace, scenarioName));
     }