Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

update version #48

Merged
merged 1 commit into from
Dec 13, 2023
Merged

update version #48

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion build.gradle
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ ext {
springBootVersion = '2.7.6'

versions = [
revConductor : '3.14.0',
revConductor : '3.15.0',
revTestContainer : '1.17.2',
revGuava : '32.0.0-jre',
revLog4j : '2.17.1',
Expand Down
94 changes: 80 additions & 14 deletions test-harness/src/test/java/io/orkes/conductor/client/e2e/DynamicForkOptionalTests.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,7 @@
*/
package io.orkes.conductor.client.e2e;

import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import java.util.*;
import java.util.concurrent.TimeUnit;

import org.junit.jupiter.api.Test;
Expand Down Expand Up @@ -54,27 +52,34 @@ public void testTaskDynamicForkOptional() {
startWorkflowRequest.setVersion(1);

String workflowId = workflowClient.startWorkflow(startWorkflowRequest);
System.out.println("Started " + workflowId);

Workflow workflow = workflowClient.getWorkflow(workflowId, true);
TaskResult taskResult = new TaskResult();
taskResult.setWorkflowInstanceId(workflowId);
taskResult.setTaskId(workflow.getTasks().get(0).getTaskId());
taskResult.setStatus(TaskResult.Status.COMPLETED);

WorkflowTask workflowTask2 = new WorkflowTask();
workflowTask2.setName("integration_task_2");
workflowTask2.setTaskReferenceName("xdt1");
List<WorkflowTask> fanoutTasks = new ArrayList<>();
Map<String, Map<String, Object>> input = new HashMap<>();

for (int i = 0; i < 100; i++) {
WorkflowTask workflowTask = new WorkflowTask();
workflowTask.setName("integration_task_2");
workflowTask.setTaskReferenceName("xdt" + i);
workflowTask.setOptional(true);
fanoutTasks.add(workflowTask);

input.put("xdt" + i, Map.of("k1", "v1"));

}



WorkflowTask workflowTask3 = new WorkflowTask();
workflowTask3.setName("integration_task_3");
workflowTask3.setTaskReferenceName("xdt2");
workflowTask3.setOptional(true);

Map<String, Object> output = new HashMap<>();
Map<String, Map<String, Object>> input = new HashMap<>();
input.put("xdt1", Map.of("k1", "v1"));
input.put("xdt2", Map.of("k2", "v2"));
output.put("dynamicTasks", Arrays.asList(workflowTask2, workflowTask3));

output.put("dynamicTasks", fanoutTasks);
output.put("dynamicTasksInput", input);
taskResult.setOutputData(output);
taskClient.updateTask(taskResult);
Expand Down Expand Up @@ -168,6 +173,67 @@ public void testTaskDynamicForkOptional() {
metadataClient.unregisterWorkflowDef(workflowName1, 1);
}


@Test
public void testLargeFork() {

String workflowName1 = "DynamicFanInOutTest";
int count = 200;

// Register workflow
registerWorkflowDef(workflowName1, metadataClient);

// Trigger workflow
StartWorkflowRequest startWorkflowRequest = new StartWorkflowRequest();
startWorkflowRequest.setName(workflowName1);
startWorkflowRequest.setVersion(1);

String workflowId = workflowClient.startWorkflow(startWorkflowRequest);
System.out.println("Started " + workflowId);

Workflow workflow = workflowClient.getWorkflow(workflowId, true);
TaskResult taskResult = new TaskResult();
taskResult.setWorkflowInstanceId(workflowId);
taskResult.setTaskId(workflow.getTasks().get(0).getTaskId());
taskResult.setStatus(TaskResult.Status.COMPLETED);

List<WorkflowTask> fanoutTasks = new ArrayList<>();
Map<String, Map<String, Object>> input = new HashMap<>();

for (int i = 0; i < count; i++) {
WorkflowTask workflowTask = new WorkflowTask();
workflowTask.setName("integration_task_2");
workflowTask.setTaskReferenceName("xdt" + i);
workflowTask.setOptional(true);
fanoutTasks.add(workflowTask);

input.put("xdt" + i, Map.of("k1", "v1"));

}

Map<String, Object> output = new HashMap<>();

output.put("dynamicTasks", fanoutTasks);
output.put("dynamicTasksInput", input);
taskResult.setOutputData(output);
taskClient.updateTask(taskResult);

workflow = workflowClient.getWorkflow(workflowId, true);
for (Task task : workflow.getTasks()) {
if(!task.getStatus().isTerminal()) {
taskResult = new TaskResult();
taskResult.setWorkflowInstanceId(workflowId);
taskResult.setTaskId(task.getTaskId());
taskResult.setStatus(TaskResult.Status.COMPLETED);
taskClient.updateTask(taskResult);
}
}
workflow = workflowClient.getWorkflow(workflowId, true);
System.out.println("workflow status: " + workflow.getStatus());


}

@Test
public void testTaskDynamicForkRetryCount() {

Expand Down
Loading