Kubernetes: wait for proxy.container-wait-time before pod is ready

openanalytics · Nov 9, 2020 · 8ba1258 · 8ba1258
1 parent 1a64723
commit 8ba1258
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/java/eu/openanalytics/containerproxy/backend/kubernetes/KubernetesBackend.java b/src/main/java/eu/openanalytics/containerproxy/backend/kubernetes/KubernetesBackend.java
@@ -268,8 +268,11 @@ protected Container startContainer(ContainerSpec spec, Proxy proxy) throws Excep
 
 		Pod startedPod = kubeClient.pods().inNamespace(effectiveKubeNamespace).create(patchedPod);
 
-		// Workaround: waitUntilReady appears to be buggy.
-		Retrying.retry(i -> Readiness.isReady(kubeClient.resource(startedPod).fromServer().get()), 60, 1000);
+		int totalWaitMs = Integer.parseInt(environment.getProperty("proxy.container-wait-time", "20000"));
+		Retrying.retry(i -> Readiness.isReady(kubeClient.resource(startedPod).fromServer().get()), totalWaitMs / 1000, 1000);
+		if (!Readiness.isReady(kubeClient.resource(startedPod).fromServer().get())) {
+			throw new ContainerProxyException("Container did not become ready in time");
+		}
 		Pod pod = kubeClient.resource(startedPod).fromServer().get();
 
 		Service service = null;