openwhisk-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dube...@apache.org
Subject [incubator-openwhisk-package-kafka] branch master updated: More test improvements (#251)
Date Mon, 26 Feb 2018 20:38:16 GMT
This is an automated email from the ASF dual-hosted git repository.

dubeejw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-openwhisk-package-kafka.git


The following commit(s) were added to refs/heads/master by this push:
     new 96fd5af  More test improvements (#251)
96fd5af is described below

commit 96fd5af8fef2b25b281ce652ce6f7b88cdb33f46
Author: Adnan Baruni <abaruni@users.noreply.github.com>
AuthorDate: Mon Feb 26 14:38:14 2018 -0600

    More test improvements (#251)
    
    * add additional time for consumer init and up retry value
    
    * update produce tests to not fail immediately with multiple activations
---
 tests/src/test/scala/system/health/BasicHealthTest.scala          | 8 +++++++-
 tests/src/test/scala/system/packages/MessageHubProduceTests.scala | 4 ++--
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/tests/src/test/scala/system/health/BasicHealthTest.scala b/tests/src/test/scala/system/health/BasicHealthTest.scala
index 52b176d..02183d2 100644
--- a/tests/src/test/scala/system/health/BasicHealthTest.scala
+++ b/tests/src/test/scala/system/health/BasicHealthTest.scala
@@ -87,8 +87,14 @@ class BasicHealthTest
         activation =>
           // should be successful
           activation.response.success shouldBe true
+
+          // It takes a moment for the consumer to fully initialize.
+          println("Giving the consumer a moment to get ready")
+          Thread.sleep(consumerInitTime)
+
           val uuid = activation.response.result.get.fields.get("uuid").get.toString().replaceAll("\"",
"")
 
+          println("Checking health endpoint(s) for existence of consumer uuid")
           // get /health endpoint(s) and ensure it contains the new uuid
           val healthUrls = System.getProperty("health_url").split("\\s*,\\s*").filterNot(_.isEmpty)
           healthUrls shouldNot be(empty)
@@ -111,7 +117,7 @@ class BasicHealthTest
 
             uuids should contain(uuid)
 
-          }, N = 3, waitBeforeRetry = Some(1.second))
+          }, N = 10, waitBeforeRetry = Some(1.second))
       }
   }
 
diff --git a/tests/src/test/scala/system/packages/MessageHubProduceTests.scala b/tests/src/test/scala/system/packages/MessageHubProduceTests.scala
index eb4bcd1..3c2aac8 100644
--- a/tests/src/test/scala/system/packages/MessageHubProduceTests.scala
+++ b/tests/src/test/scala/system/packages/MessageHubProduceTests.scala
@@ -200,7 +200,7 @@ class MessageHubProduceTests
             // verify trigger fired
             println("Polling for activations")
             val activations = wsk.activation.pollFor(N = 1, Some(triggerName), retries =
maxRetries)
-            assert(activations.length == 1)
+            assert(activations.length > 0)
 
             val matchingActivations = for {
                 id <- activations
@@ -269,7 +269,7 @@ class MessageHubProduceTests
             // verify trigger fired
             println("Polling for activations")
             val activations = wsk.activation.pollFor(N = 1, Some(triggerName), retries =
maxRetries)
-            assert(activations.length == 1)
+            assert(activations.length > 0)
 
             val matchingActivations = for {
                 id <- activations

-- 
To stop receiving notification emails like this one, please contact
dubeejw@apache.org.

Mime
View raw message