fixing deployment resource consistence

ppgia-unifor · Jul 29, 2024 · 7b167c8 · 7b167c8
1 parent d305fca
commit 7b167c8
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/...ence-bench/operator/src/main/java/io/resiliencebench/execution/steps/EnvironmentStep.java b/...ence-bench/operator/src/main/java/io/resiliencebench/execution/steps/EnvironmentStep.java
@@ -18,6 +18,8 @@
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
+import static io.resiliencebench.support.Annotations.CONTAINER;
+
 @Service
 public class EnvironmentStep extends ExecutorStep<Deployment> {
 
@@ -44,7 +46,7 @@ protected boolean isApplicable(Scenario scenario) {
   public void applyServiceEnvironment(Scenario scenario, io.resiliencebench.resources.scenario.Service service) {
     var env = service.getEnvs();
     var resilientService = resilientServiceRepository.get(scenario.getMetadata().getNamespace(), service.getName());
-    var containerName = resilientService.getMetadata().getAnnotations().get("resiliencebench.io/container");
+    var containerName = resilientService.getMetadata().getAnnotations().get(CONTAINER);
 
     var deployment = kubernetesClient()
             .apps()
@@ -89,8 +91,13 @@ public void applyNewVariables(Deployment targetDeployment, String containerName,
       }
     }
 
-    logger.info("Deleting pods for deployment {}", targetDeployment.getMetadata().getName());
-    getPods(targetDeployment).delete();
+    kubernetesClient().apps().deployments()
+            .inNamespace(targetDeployment.getMetadata().getNamespace())
+            .resource(targetDeployment)
+            .update();
+
+//    logger.info("Deleting pods for deployment {}", targetDeployment.getMetadata().getName());
+//    getPods(targetDeployment).delete();
     logger.info("Waiting for the pods to restart.");
     getPods(targetDeployment).waitUntilCondition(this::waitUntilCondition, 60, TimeUnit.SECONDS);
     logger.info("Pods restarted successfully");

diff --git a/resilience-bench/operator/src/main/java/io/resiliencebench/support/Annotations.java b/resilience-bench/operator/src/main/java/io/resiliencebench/support/Annotations.java
@@ -5,4 +5,6 @@ public interface Annotations {
   String OWNED_BY = "resiliencebench.io/owned-by";
 
   String CREATED_BY = "resiliencebench.io/created-by";
+
+  String CONTAINER = "resiliencebench.io/container";
 }