ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-18 18:56:28 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Print remaining k8s pods on pod completion (#5697)

Browse Source 
* TM-87 printing remaining pods on pod completion

* TM-87 extra commit to unblock jenkins?

* TM-87 extra commit to unblock jenkins?

* TM-87 pr comments
This commit is contained in:
Razvan Codreanu 2019-11-13 11:32:54 +00:00 committed by Stefano Franz
parent bec865dc57
commit 71af7ad7cb
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
buildSrc/src/main/groovy/net/corda/testing/KubesTest.java
View File

@ -74,6 +74,7 @@ public class KubesTest extends DefaultTask {
Integer memoryGbPerFork = 6; Integer memoryGbPerFork = 6;
public volatile List<File> testOutput = Collections.emptyList(); public volatile List<File> testOutput = Collections.emptyList();
public volatile List<KubePodResult> containerResults = Collections.emptyList(); public volatile List<KubePodResult> containerResults = Collections.emptyList();
private final List<String> remainingPods = Collections.synchronizedList(new ArrayList());
public static String NAMESPACE = "thisisatest"; public static String NAMESPACE = "thisisatest";
int k8sTimeout = 50 * 1_000; int k8sTimeout = 50 * 1_000;
@ -227,6 +228,7 @@ public class KubesTest extends DefaultTask {
} }
getProject().getLogger().lifecycle("creating pod: " + podName); getProject().getLogger().lifecycle("creating pod: " + podName);
createdPod = client.pods().inNamespace(namespace).create(buildPodRequest(podName, pvc)); createdPod = client.pods().inNamespace(namespace).create(buildPodRequest(podName, pvc));
remainingPods.add(podName);
getProject().getLogger().lifecycle("scheduled pod: " + podName); getProject().getLogger().lifecycle("scheduled pod: " + podName);
} }
@ -256,6 +258,11 @@ public class KubesTest extends DefaultTask {
try (KubernetesClient client = getKubernetesClient()) { try (KubernetesClient client = getKubernetesClient()) {
client.pods().delete(createdPod); client.pods().delete(createdPod);
client.persistentVolumeClaims().delete(pvc); client.persistentVolumeClaims().delete(pvc);
synchronized (remainingPods) {
remainingPods.remove(podName);
getLogger().lifecycle("Remaining Pods: ");
remainingPods.forEach(pod -> getLogger().lifecycle("\t" + pod));
}
} }
return new KubePodResult(podIdx, resCode, podOutput, binaryResults); return new KubePodResult(podIdx, resCode, podOutput, binaryResults);
}); });