Make runtime delete timeout configurable (#5028)

Co-authored-by: ning.yougang <[email protected]>

Author: ningyougang

core/invoker/src/main/resources/application.conf

@@ -173,4 +173,5 @@ whisk {
   invoker {
     protocol: http
   }
+  runtime.delete.timeout = "30 seconds"
 }

core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/kubernetes/KubernetesContainerFactory.scala

@@ -64,7 +64,7 @@ class KubernetesContainerFactory(
     logging.info(this, "Cleaning up function runtimes")
     val labels = Map("invoker" -> label, "release" -> KubernetesContainerFactoryProvider.release)
     val cleaning = kubernetes.rm(labels, true)(TransactionId.invokerNanny)
-    Await.ready(cleaning, 30.seconds)
+    Await.ready(cleaning, KubernetesContainerFactoryProvider.runtimeDeleteTimeout)
   }
 
   override def createContainer(tid: TransactionId,
@@ -90,6 +90,7 @@ class KubernetesContainerFactory(
 object KubernetesContainerFactoryProvider extends ContainerFactoryProvider {
 
   val release = loadConfigOrThrow[String]("whisk.helm.release")
+  val runtimeDeleteTimeout = loadConfigOrThrow[FiniteDuration]("whisk.runtime.delete.timeout")
 
   override def instance(actorSystem: ActorSystem,
                         logging: Logging,

core/standalone/src/main/resources/standalone-kcf.conf

@@ -34,4 +34,5 @@ whisk {
     port-forwarding-enabled = true
   }
   helm.release = "release"
+  runtime.delete.timeout = "30 seconds"
 }

tests/src/test/resources/application.conf.j2

@@ -103,6 +103,7 @@ whisk {
     }
 
     helm.release = "release"
+    runtime.delete.timeout = "30 seconds"
 }
 
 #test-only overrides so that tests can override defaults in application.conf (todo: move all defaults to reference.conf)