@PublicAPI public class TaskFlowJob extends Job
addTask(Task)
in order to fill the job with your own tasks.description, globalSpace, inputSpace, JOB_DDL, JOB_EXEC_TIME, name, outputSpace, priority, projectName, unresolvedVariables, userSpace, variables, visualization
GENERIC_INFO_START_AT_KEY, genericInformation, maxNumberOfExecution, onTaskError, restartTaskOnError, unresolvedGenericInformation
Constructor and Description |
---|
TaskFlowJob()
ProActive Empty Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
addTask(Task task)
Add a task to this task flow job.
The task name must not be null as it is not by default. The task name must also be different for each task as it is used to identify each task result. If not set, the task name will be a generated one : 'task_X' (where X is the Xth added task number) |
void |
addTasks(List<Task> tasks)
Add a list of tasks to this task flow job.
|
String |
display() |
JobId |
getId()
To get the id
|
Task |
getTask(String name)
Get the task corresponding to the given name.
|
ArrayList<Task> |
getTasks()
To get the list of tasks.
|
JobType |
getType()
To get the type of this job
|
getDescription, getGlobalSpace, getInputSpace, getJobContent, getJobDeadline, getJobExpectedExecutionTime, getName, getOutputSpace, getPriority, getProjectName, getUnresolvedVariables, getUserSpace, getVariables, getVariablesAsReplacementMap, getVisualization, setDescription, setGlobalSpace, setInputSpace, setJobContent, setName, setOutputSpace, setPriority, setProjectName, setUnresolvedVariables, setUserSpace, setVariables, setVisualization, toString, verifyVariableMap
addGenericInformation, addGenericInformations, applyReplacementsOnGenericInformation, getGenericInformation, getMaxNumberOfExecution, getMaxNumberOfExecutionProperty, getOnTaskErrorProperty, getRestartTaskOnError, getRestartTaskOnErrorProperty, getUnresolvedGenericInformation, setGenericInformation, setMaxNumberOfExecution, setOnTaskError, setRestartTaskOnError, setUnresolvedGenericInformation
public JobType getType()
Job
getType
in class Job
Job.getType()
public void addTask(Task task) throws UserException
task
- the task to add.UserException
- if a problem occurred while the task is being added.public void addTasks(List<Task> tasks) throws UserException
tasks
- the list of tasks to add.UserException
- if a problem occurred while the task is being added.public Task getTask(String name)
name
- the name of the task to look for.public JobId getId()
Job
getId
in class Job
Job.getId()