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 <abar...@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 dube...@apache.org.