check

TouK · Jan 20, 2025 · 4d72c19 · 4d72c19
1 parent f31b6bf
commit 4d72c19
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/...anager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala b/...anager/src/test/scala/pl/touk/nussknacker/k8s/manager/K8sDeploymentManagerKafkaTest.scala
@@ -148,19 +148,19 @@ class K8sDeploymentManagerKafkaTest
 //          ).asJava
 //        )
 //      )
-//      .withValue(
-//        "resources",
-//        fromMap(
-//          Map(
-//            "requests" -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava),
-//            "limits"   -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava)
-//          ).asJava
-//        )
-//      )
+      .withValue(
+        "resources",
+        fromMap(
+          Map(
+            "requests" -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava),
+            "limits"   -> fromMap(Map("memory" -> "256Mi", "cpu" -> "800m").asJava)
+          ).asJava
+        )
+      )
       .root()
     val f = createKafkaFixture(
       deployConfig = kafkaDeployConfig
-//        .withValue("k8sDeploymentConfig.spec.replicas", fromAnyRef(3))
+        .withValue("k8sDeploymentConfig.spec.replicas", fromAnyRef(3))
         .withValue(
           "k8sDeploymentConfig.spec.template.spec.containers",
           fromIterable(List(runtimeContainerConfig).asJava)
@@ -169,7 +169,7 @@ class K8sDeploymentManagerKafkaTest
     f.withRunningScenario {
       eventually {
         val pods = k8s.listSelected[ListResource[Pod]](requirementForName(f.version.processName)).futureValue.items
-        pods.size shouldBe 1
+        pods.size shouldBe 3
         forAll(pods.head.spec.get.containers) { container =>
           container.resources shouldBe Some(
             skuber.Resource.Requirements(