|
12 | 12 | import io.skodjob.testframe.resources.JobType;
|
13 | 13 | import io.skodjob.testframe.resources.KubeResourceManager;
|
14 | 14 | import io.skodjob.testframe.resources.NamespaceType;
|
| 15 | +import io.skodjob.testframe.utils.KubeUtils; |
15 | 16 | import io.strimzi.systemtest.exceptions.KubernetesClusterUnstableException;
|
16 | 17 | import io.strimzi.systemtest.interfaces.IndicativeSentences;
|
17 | 18 | import io.strimzi.systemtest.logs.TestExecutionWatcher;
|
|
46 | 47 | import org.junit.jupiter.api.extension.ExtensionContext;
|
47 | 48 |
|
48 | 49 | import java.util.Collections;
|
49 |
| -import java.util.HashMap; |
50 | 50 | import java.util.List;
|
51 |
| -import java.util.Map; |
52 | 51 |
|
53 | 52 | import static io.strimzi.systemtest.matchers.Matchers.logHasNoUnexpectedErrors;
|
54 | 53 | import static io.strimzi.test.k8s.KubeClusterResource.cmdKubeClient;
|
@@ -84,17 +83,23 @@ public abstract class AbstractST implements TestSeparator {
|
84 | 83 |
|
85 | 84 | KubeResourceManager.get().addCreateCallback(resource -> {
|
86 | 85 | if (resource instanceof Namespace namespace) {
|
87 |
| - Map<String, String> labels = new HashMap<>(namespace.getMetadata().getLabels()); |
88 |
| - labels.put(TestConstants.TEST_SUITE_NAME_LABEL, StUtils.removePackageName(KubeResourceManager.get().getTestContext().getRequiredTestClass().getName())); |
| 86 | + String testClass = StUtils.removePackageName(KubeResourceManager.get().getTestContext().getRequiredTestClass().getName()); |
| 87 | + |
| 88 | + KubeUtils.labelNamespace( |
| 89 | + namespace.getMetadata().getName(), |
| 90 | + TestConstants.TEST_SUITE_NAME_LABEL, |
| 91 | + testClass |
| 92 | + ); |
89 | 93 |
|
90 | 94 | if (KubeResourceManager.get().getTestContext().getTestMethod().isPresent()) {
|
91 | 95 | String testCaseName = KubeResourceManager.get().getTestContext().getRequiredTestMethod().getName();
|
92 |
| - labels.put(TestConstants.TEST_CASE_NAME_LABEL, testCaseName); |
93 |
| - } |
94 | 96 |
|
95 |
| - namespace.getMetadata().setLabels(labels); |
96 |
| - |
97 |
| - KubeResourceManager.get().kubeClient().getClient().resource(namespace).update(); |
| 97 | + KubeUtils.labelNamespace( |
| 98 | + namespace.getMetadata().getName(), |
| 99 | + TestConstants.TEST_CASE_NAME_LABEL, |
| 100 | + testCaseName |
| 101 | + ); |
| 102 | + } |
98 | 103 | }
|
99 | 104 | });
|
100 | 105 | }
|
|
0 commit comments