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 <[email protected]>
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)