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)