[oodt] branch master updated: Improve reliability of TestAvroRpcWorkflowManager test

[im...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

imesha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/oodt.git


The following commit(s) were added to refs/heads/master by this push:
     new 8dcea1d  Improve reliability of TestAvroRpcWorkflowManager test
8dcea1d is described below

commit 8dcea1db231a5f1fd7c683c969d35af3ffa65fed
Author: Imesha Sudasingha <im...@gmail.com>
AuthorDate: Sat Sep 25 20:05:51 2021 +0530

    Improve reliability of TestAvroRpcWorkflowManager test
---
 .../apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java
index b09c50e..b01ac7b 100644
--- a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java
+++ b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java
@@ -51,7 +51,8 @@ public class TestAvroRpcWorkflowManager extends TestCase{
      * number of workflow instances are 2 when asserting.
      */
     @Test
-    public void testGetWorkflowInstances() {
+    public void testGetWorkflowInstances() throws InterruptedException {
+        Thread.sleep(5000);
 
         Vector workflowInsts = null;
 
@@ -87,7 +88,7 @@ public class TestAvroRpcWorkflowManager extends TestCase{
                      new AvroRpcWorkflowManagerClient(new URL("http://localhost:" + WM_PORT))) {
             Metadata metadata = new Metadata();
             // Hold the task for 20 seconds at least            
-            metadata.addMetadata("numSeconds", String.valueOf(20));
+            metadata.addMetadata("numSeconds", String.valueOf(30));
             client.sendEvent("long", metadata);
         } catch (Exception e) {
             fail(e.getMessage());