You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openwhisk.apache.org by ty...@apache.org on 2020/03/13 00:20:44 UTC
[openwhisk] branch master updated: fix creation logic broken from
wait changes (#4860)
This is an automated email from the ASF dual-hosted git repository.
tysonnorris pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/openwhisk.git
The following commit(s) were added to refs/heads/master by this push:
new 3cc850f fix creation logic broken from wait changes (#4860)
3cc850f is described below
commit 3cc850f2ae637ba40c4fc044d19de1d9bae4821c
Author: tysonnorris <tn...@adobe.com>
AuthorDate: Thu Mar 12 17:20:29 2020 -0700
fix creation logic broken from wait changes (#4860)
---
.../openwhisk/core/containerpool/kubernetes/KubernetesClient.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/kubernetes/KubernetesClient.scala b/core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/kubernetes/KubernetesClient.scala
index 9637d2d..322ade9 100644
--- a/core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/kubernetes/KubernetesClient.scala
+++ b/core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/kubernetes/KubernetesClient.scala
@@ -139,13 +139,14 @@ class KubernetesClient(
//create the pod; catch any failure to end the transaction timer
val createdPod = try {
- kubeRestClient.pods.inNamespace(namespace).create(pod)
+ val created = kubeRestClient.pods.inNamespace(namespace).create(pod)
pdb.map(
p =>
kubeRestClient.policy.podDisruptionBudget
.inNamespace(namespace)
.withName(name)
.create(p))
+ created
} catch {
case e: Throwable =>
transid.failed(this, start, s"Failed create pod for '$name': ${e.getClass} - ${e.getMessage}", ErrorLevel)