Package gri.tasks.managers.workflows

Examples of gri.tasks.managers.workflows.WorkflowSubmission.addJob()

90
91
92
93
94
95
96
97
98
99
100
      if (name.equals("job")) {
    String taskId = JobSubmissionSerializer.readTaskId(child);
    JobSubmissionSerializer serializer = serializers.
      getJobSubmissionSerializer(jobIndex, taskId, config);
    JobSubmission job = serializer.readJob(child);
    submission.addJob(job);
   
    jobIndex++;
      }
  }
 
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
 
  WorkflowSubmission wkfl = new WorkflowSubmission();
 
  JobSubmission job1 = new JobSubmission("dan.encryption.Digest.md5");
  job1.setInput("message", "dude");
  wkfl.addJob(job1);

  JobSubmission job2 = new JobSubmission("dan.encryption.Digest.md5");
  job2.setInput("message", "dude");
  job2.setInput("message", new WorkflowOutputReference(0, "digest"));
  wkfl.addJob(job2);
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
  wkfl.addJob(job1);

  JobSubmission job2 = new JobSubmission("dan.encryption.Digest.md5");
  job2.setInput("message", "dude");
  job2.setInput("message", new WorkflowOutputReference(0, "digest"));
  wkfl.addJob(job2);
 
  return wkfl;
    }
   
    protected static WorkflowSubmission createFileWorkflow() {
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
  WorkflowSubmission wkfl = new WorkflowSubmission();
 
  JobSubmission job1 = new JobSubmission("dan.encryption.Digest.digestToHex");
  job1.setInput("file", new TextMemFile("input1.txt", "dude"));
  job1.setInput("algorithm", "MD5");
  wkfl.addJob(job1);
 
  JobSubmission job2 = new JobSubmission("dan.encryption.Digest.digestToHex");
  job2.setInput("file", new TextMemFile("input2.txt", "dude"));
  job2.setInput("algorithm", "MD5");
  wkfl.addJob(job2);
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
  wkfl.addJob(job1);
 
  JobSubmission job2 = new JobSubmission("dan.encryption.Digest.digestToHex");
  job2.setInput("file", new TextMemFile("input2.txt", "dude"));
  job2.setInput("algorithm", "MD5");
  wkfl.addJob(job2);
 
  return wkfl;
    }
   
    protected static TaskProvider loadTaskProvider() throws Exception {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.