Guest User

Untitled

a guest
Nov 19th, 2017
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.42 KB | None | 0 0
  1. private static Workflow.Builder createWorkflow() {
  2. List<TaskConfig> downloadDataTasks = new ArrayList<>();
  3. downloadDataTasks.add(new TaskConfig.Builder().setTaskId("Download_Task").setCommand(DataCollectingTask.NAME).build());
  4.  
  5. List<TaskConfig> commandExecuteTasks = new ArrayList<>();
  6. commandExecuteTasks.add(new TaskConfig.Builder().setTaskId("Command_Task").setCommand(CommandTask.NAME).build());
  7.  
  8. List<TaskConfig> pushDataTasks = new ArrayList<>();
  9. pushDataTasks.add(new TaskConfig.Builder().setTaskId("Push_Task").setCommand(DataPushingTask.NAME).build());
  10.  
  11. JobConfig.Builder downloadDataJob = new JobConfig.Builder().addTaskConfigs(downloadDataTasks).setMaxAttemptsPerTask(3);
  12. JobConfig.Builder commandExecuteJob = new JobConfig.Builder().addTaskConfigs(commandExecuteTasks).setMaxAttemptsPerTask(3);
  13. JobConfig.Builder dataPushJob = new JobConfig.Builder().addTaskConfigs(pushDataTasks).setMaxAttemptsPerTask(3);
  14.  
  15. Workflow.Builder workflow = new Workflow.Builder("Airavata_Workflow").setExpiry(0);
  16. workflow.addJob("downloadDataJob", downloadDataJob);
  17. workflow.addJob("commandExecuteJob", commandExecuteJob);
  18. workflow.addJob("dataPushJob", dataPushJob);
  19.  
  20. workflow.addParentChildDependency("downloadDataJob", "commandExecuteJob");
  21. workflow.addParentChildDependency("commandExecuteJob", "dataPushJob");
  22.  
  23. return workflow;
  24. }
Add Comment
Please, Sign In to add comment