Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private static Workflow.Builder createWorkflow() {
- List<TaskConfig> downloadDataTasks = new ArrayList<>();
- downloadDataTasks.add(new TaskConfig.Builder().setTaskId("Download_Task").setCommand(DataCollectingTask.NAME).build());
- List<TaskConfig> commandExecuteTasks = new ArrayList<>();
- commandExecuteTasks.add(new TaskConfig.Builder().setTaskId("Command_Task").setCommand(CommandTask.NAME).build());
- List<TaskConfig> pushDataTasks = new ArrayList<>();
- pushDataTasks.add(new TaskConfig.Builder().setTaskId("Push_Task").setCommand(DataPushingTask.NAME).build());
- JobConfig.Builder downloadDataJob = new JobConfig.Builder().addTaskConfigs(downloadDataTasks).setMaxAttemptsPerTask(3);
- JobConfig.Builder commandExecuteJob = new JobConfig.Builder().addTaskConfigs(commandExecuteTasks).setMaxAttemptsPerTask(3);
- JobConfig.Builder dataPushJob = new JobConfig.Builder().addTaskConfigs(pushDataTasks).setMaxAttemptsPerTask(3);
- Workflow.Builder workflow = new Workflow.Builder("Airavata_Workflow").setExpiry(0);
- workflow.addJob("downloadDataJob", downloadDataJob);
- workflow.addJob("commandExecuteJob", commandExecuteJob);
- workflow.addJob("dataPushJob", dataPushJob);
- workflow.addParentChildDependency("downloadDataJob", "commandExecuteJob");
- workflow.addParentChildDependency("commandExecuteJob", "dataPushJob");
- return workflow;
- }
Add Comment
Please, Sign In to add comment