third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: workflow instance return init params too #92

Browse Source
This commit is contained in:
“tjq” 2020-11-07 22:04:04 +08:00
parent 7ac70defd3
commit 5cf43ddb2a
3 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
powerjob-client/src/test/java/TestWorkflow.java
View File

@ -22,6 +22,8 @@ public class TestWorkflow {
private static OhMyClient ohMyClient;
private static final long WF_ID = 1;
@BeforeAll
public static void initClient() throws Exception {
ohMyClient = new OhMyClient("127.0.0.1:7700", "powerjob-agent-test", "123");
@ -70,27 +72,27 @@ public class TestWorkflow {
@Test
public void testDisableWorkflow() throws Exception {
System.out.println(ohMyClient.disableWorkflow(4L));
System.out.println(ohMyClient.disableWorkflow(WF_ID));
}
@Test
public void testDeleteWorkflow() throws Exception {
System.out.println(ohMyClient.deleteWorkflow(4L));
System.out.println(ohMyClient.deleteWorkflow(WF_ID));
}
@Test
public void testEnableWorkflow() throws Exception {
System.out.println(ohMyClient.enableWorkflow(4L));
System.out.println(ohMyClient.enableWorkflow(WF_ID));
}
@Test
public void testFetchWorkflowInfo() throws Exception {
System.out.println(ohMyClient.fetchWorkflow(5L));
System.out.println(ohMyClient.fetchWorkflow(WF_ID));
}
@Test
public void testRunWorkflow() throws Exception {
System.out.println(ohMyClient.runWorkflow(5L));
System.out.println(ohMyClient.runWorkflow(WF_ID));
}
@Test
@ -105,6 +107,6 @@ public class TestWorkflow {
@Test
public void testRunWorkflowPlus() throws Exception {
System.out.println(ohMyClient.runWorkflow(1L, "this is init Params 2", 90000));
System.out.println(ohMyClient.runWorkflow(WF_ID, "this is init Params 2", 90000));
}
}

2
powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/WorkflowInstanceInfoDTO.java
View File

@ -21,6 +21,8 @@ public class WorkflowInstanceInfoDTO {
// workflow 状态（WorkflowInstanceStatus）
private Integer status;
// 工作流启动参数
private String wfInitParams;
private String dag;
private String result;

2
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkflowInstanceInfoVO.java
View File

@ -26,6 +26,8 @@ public class WorkflowInstanceInfoVO {
// workflow 状态（WorkflowInstanceStatus）
private Integer status;
// 工作流启动参数
private String wfInitParams;
private PEWorkflowDAG pEWorkflowDAG;
private String result;