uncomment tests

Author: valerena

integration/combination/test_function_with_msk.py

@@ -25,12 +25,12 @@ def test_function_with_msk_trigger(self):
         parameters.append(self.generate_parameter("MskClusterName", cluster_name))
         self._common_validations_for_MSK("combination/function_with_msk", parameters)
 
-    # def test_function_with_msk_trigger_using_manage_policy(self):
-    #     companion_stack_outputs = self.companion_stack_outputs
-    #     parameters = self.get_parameters(companion_stack_outputs)
-    #     cluster_name = "MskCluster2-" + generate_suffix()
-    #     parameters.append(self.generate_parameter("MskClusterName2", cluster_name))
-    #     self._common_validations_for_MSK("combination/function_with_msk_using_managed_policy", parameters)
+    def test_function_with_msk_trigger_using_manage_policy(self):
+        companion_stack_outputs = self.companion_stack_outputs
+        parameters = self.get_parameters(companion_stack_outputs)
+        cluster_name = "MskCluster2-" + generate_suffix()
+        parameters.append(self.generate_parameter("MskClusterName2", cluster_name))
+        self._common_validations_for_MSK("combination/function_with_msk_using_managed_policy", parameters)
 
     def test_function_with_msk_trigger_and_s3_onfailure_events_destinations(self):
         companion_stack_outputs = self.companion_stack_outputs
@@ -41,14 +41,14 @@ def test_function_with_msk_trigger_and_s3_onfailure_events_destinations(self):
             "combination/function_with_msk_trigger_and_s3_onfailure_events_destinations", parameters
         )
 
-    # def test_function_with_msk_trigger_and_confluent_schema_registry(self):
-    #     companion_stack_outputs = self.companion_stack_outputs
-    #     parameters = self.get_parameters(companion_stack_outputs)
-    #     cluster_name = "MskCluster4-" + generate_suffix()
-    #     parameters.append(self.generate_parameter("MskClusterName4", cluster_name))
-    #     self._common_validations_for_MSK(
-    #         "combination/function_with_msk_trigger_and_confluent_schema_registry", parameters
-    #     )
+    def test_function_with_msk_trigger_and_confluent_schema_registry(self):
+        companion_stack_outputs = self.companion_stack_outputs
+        parameters = self.get_parameters(companion_stack_outputs)
+        cluster_name = "MskCluster4-" + generate_suffix()
+        parameters.append(self.generate_parameter("MskClusterName4", cluster_name))
+        self._common_validations_for_MSK(
+            "combination/function_with_msk_trigger_and_confluent_schema_registry", parameters
+        )
 
     def _common_validations_for_MSK(self, file_name, parameters):
         self.create_and_verify_stack(file_name, parameters)