You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by ma...@apache.org on 2015/11/06 01:05:13 UTC
oodt git commit: OODT-917 tests for WM to validate XMLRPC interface
Repository: oodt
Updated Branches:
refs/heads/master 538c0d6ba -> 6c58b743a
OODT-917 tests for WM to validate XMLRPC interface
Project: http://git-wip-us.apache.org/repos/asf/oodt/repo
Commit: http://git-wip-us.apache.org/repos/asf/oodt/commit/6c58b743
Tree: http://git-wip-us.apache.org/repos/asf/oodt/tree/6c58b743
Diff: http://git-wip-us.apache.org/repos/asf/oodt/diff/6c58b743
Branch: refs/heads/master
Commit: 6c58b743a581428410918d4d897d7ad4b91c6bc8
Parents: 538c0d6
Author: Tom Barber <to...@analytical-labs.com>
Authored: Thu Nov 5 22:09:34 2015 +0000
Committer: Tom Barber <to...@analytical-labs.com>
Committed: Thu Nov 5 22:09:34 2015 +0000
----------------------------------------------------------------------
.../system/TestXmlRpcWorkflowManagerClient.java | 163 ++++++++++++++++++-
1 file changed, 161 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/oodt/blob/6c58b743/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
----------------------------------------------------------------------
diff --git a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
index a12ea19..94c3bee 100644
--- a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
+++ b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
@@ -283,13 +283,12 @@ public class TestXmlRpcWorkflowManagerClient {
}
- @Ignore
@Test
public void testGetNumWorkflowInstancesByStatus() throws Exception {
int inst = fmc.getNumWorkflowInstancesByStatus("QUEUED");
- fail();
+ assertThat(inst, equalTo(0));
}
@@ -322,7 +321,167 @@ public class TestXmlRpcWorkflowManagerClient {
assertNotNull(wfinstances);
}
+ @Test
+ public void testGetWFMUrl(){
+
+ URL url = fmc.getWorkflowManagerUrl();
+
+ assertThat(url, is(not(nullValue())));
+
+ assertThat(url.toString(), equalTo("http://localhost:"+WM_PORT));
+ }
+
+ @Ignore
+ @Test
+ public void testGetNullWorkflowInstances()
+ throws RepositoryException, XmlRpcException, IOException, InterruptedException {
+
+ Thread.sleep(3000);
+ WorkflowInstance instance = fmc.getWorkflowInstanceById("1234");
+
+ assertThat(instance, is(nullValue()));
+
+ }
+
+ @Test
+ public void testGetNullWorkflowInstancesByStatus() throws XmlRpcException, IOException {
+ List<WorkflowInstance> instances = fmc.getWorkflowInstancesByStatus("NULL");
+
+ assertThat(instances, is(empty()));
+
+ }
+
+ @Test
+ public void testGetWorkflowById() throws RepositoryException, XmlRpcException, IOException {
+ List<Workflow> workflowlist = fmc.getWorkflows();
+
+ assertThat(workflowlist, is(not(nullValue())));
+
+ assertThat(workflowlist.size(), is(not(0)));
+
+ Workflow work = fmc.getWorkflowById(workflowlist.get(0).getId());
+
+ assertThat(work, is(not(nullValue())));
+
+ }
+
+ @Test
+ public void testGetWorkflowInstanceById() throws XmlRpcException, IOException, RepositoryException {
+
+ List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances();
+
+ assertThat(workflowlist, is(not(nullValue())));
+
+ assertThat(workflowlist.size(), is(not(0)));
+
+ WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId());
+
+ assertThat(instance, is(not(nullValue())));
+
+ }
+
+ @Ignore
+ @Test
+ public void testUpdateMetadataForWorkflow(){
+
+ }
+
+ @Test
+ public void testUpdateWorkflowInstanceStatus() throws XmlRpcException, IOException, RepositoryException {
+
+ List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances();
+
+ assertThat(workflowlist, is(not(nullValue())));
+
+ assertThat(workflowlist.size(), is(not(0)));
+
+ WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId());
+
+ assertThat(instance, is(not(nullValue())));
+
+ boolean upd = fmc.updateWorkflowInstanceStatus(instance.getId(), "RUNNING");
+
+ assertThat(upd, equalTo(true));
+
+
+ }
+
+ @Ignore
+ @Test
+ public void testSetWorkflowInstanceCurrentTaskEndDateTime(){
+
+ }
+
+ @Ignore
+ @Test
+ public void testResumeWorkflowInstance(){
+
+ }
+
+ @Ignore
+ @Test
+ public void testPauseWorkflowInstance(){
+
+ }
+
+ @Ignore
+ @Test
+ public void testStopWorkflowInstances(){
+
+ }
+
+ @Test
+ public void testGetWorkflowWallClockMinutes() throws RepositoryException, XmlRpcException, IOException {
+ List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances();
+
+ assertThat(workflowlist, is(not(nullValue())));
+
+ assertThat(workflowlist.size(), is(not(0)));
+
+ WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId());
+
+ assertThat(instance, is(not(nullValue())));
+
+ double clock = fmc.getWorkflowWallClockMinutes(instance.getId());
+ assertThat(clock, is(not(nullValue())));
+ }
+
+ @Ignore
+ @Test
+ public void testSetWorkflowInstanceCurrentTaskStartDateTime(){
+
+ }
+
+ @Test
+ public void testPaginateWorkflowInstances() throws XmlRpcException, IOException {
+
+ WorkflowInstancePage paginate = fmc.paginateWorkflowInstances(2);
+
+ assertThat(paginate, is(not(nullValue())));
+ }
+
+ @Test
+ public void testPaginateWorkflowInstancesByStatus() throws XmlRpcException, IOException {
+
+ WorkflowInstancePage paginate = fmc.paginateWorkflowInstances(2, "QUEUED");
+
+ assertThat(paginate, is(not(nullValue())));
+ }
+ @Ignore
+ @Test
+ public void testExecuteDynamicWorkflow(){
+
+ }
+
+ @Ignore
+ @Test
+ public void testRefreshRepository() throws XmlRpcException, IOException {
+
+ boolean refresh = fmc.refreshRepository();
+
+ assertThat(refresh, equalTo(true));
+ }
@Test
public void testGetWorkflowInstanceMetadata() {