From 04e79d8b225c3e7fecc59150bda2a1b69ea79c96 Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 7 Jun 2020 19:47:28 +0800 Subject: [PATCH] [release] v2.0.0 --- .../src/test/java/TestWorkflow.java | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/oh-my-scheduler-client/src/test/java/TestWorkflow.java b/oh-my-scheduler-client/src/test/java/TestWorkflow.java index 7dd97b2a..09919b13 100644 --- a/oh-my-scheduler-client/src/test/java/TestWorkflow.java +++ b/oh-my-scheduler-client/src/test/java/TestWorkflow.java @@ -28,11 +28,14 @@ public class TestWorkflow { // DAG 图 List nodes = Lists.newLinkedList(); + List edges = Lists.newLinkedList(); nodes.add(new PEWorkflowDAG.Node(1L, "node-1")); nodes.add(new PEWorkflowDAG.Node(2L, "node-2")); - PEWorkflowDAG peWorkflowDAG = new PEWorkflowDAG(nodes, null); + edges.add(new PEWorkflowDAG.Edge(1L, 2L)); + + PEWorkflowDAG peWorkflowDAG = new PEWorkflowDAG(nodes, edges); SaveWorkflowRequest req = new SaveWorkflowRequest(); req.setWfName("workflow-by-client"); @@ -46,36 +49,36 @@ public class TestWorkflow { @Test public void testDisableWorkflow() throws Exception { - System.out.println(ohMyClient.disableWorkflow(1L)); + System.out.println(ohMyClient.disableWorkflow(4L)); } @Test public void testDeleteWorkflow() throws Exception { - System.out.println(ohMyClient.deleteWorkflow(1L)); + System.out.println(ohMyClient.deleteWorkflow(4L)); } @Test public void testEnableWorkflow() throws Exception { - System.out.println(ohMyClient.enableWorkflow(1L)); + System.out.println(ohMyClient.enableWorkflow(4L)); } @Test public void testFetchWorkflowInfo() throws Exception { - System.out.println(ohMyClient.fetchWorkflow(1L)); + System.out.println(ohMyClient.fetchWorkflow(5L)); } @Test public void testRunWorkflow() throws Exception { - System.out.println(ohMyClient.runWorkflow(1L)); + System.out.println(ohMyClient.runWorkflow(5L)); } @Test public void testStopWorkflowInstance() throws Exception { - System.out.println(ohMyClient.stopWorkflowInstance(148003202598436928L)); + System.out.println(ohMyClient.stopWorkflowInstance(149962433421639744L)); } @Test public void testFetchWfInstanceInfo() throws Exception { - System.out.println(ohMyClient.fetchWorkflowInstanceInfo(148003202598436928L)); + System.out.println(ohMyClient.fetchWorkflowInstanceInfo(149962433421639744L)); } }