WorkflowTask.h
247 std::string execution_host; // Host on which the task executed ("" if not executed successfully - yet)
249 State upcoming_visible_state; // A visible state that will become active once a WMS has process a previously sent workflow execution event
257 std::map<WorkflowFile *, std::pair<std::string, std::string>> fileTransfers; // Map of transfer files and hosts
int getNumberOfChildren() const
Get the number of children of a task.
Definition: WorkflowTask.cpp:145
void setBytesRead(unsigned long)
Set the amount of bytes read by the task.
Definition: WorkflowTask.cpp:412
Workflow * getWorkflow() const
Get the workflow that contains the task.
Definition: WorkflowTask.cpp:245
void setTaskType(TaskType)
Set the task type.
Definition: WorkflowTask.cpp:364
double getComputationEndDate()
Get the task's most recent computation end date.
Definition: WorkflowTask.cpp:674
TaskType getTaskType() const
Get the workflow task type.
Definition: WorkflowTask.cpp:356
Pending (has been submitted to a compute service)
Definition: WorkflowTask.h:69
double getMemoryRequirement() const
Get the memory requirement of the task.
Definition: WorkflowTask.cpp:135
std::string getClusterID() const
Get the cluster Id for the task.
Definition: WorkflowTask.cpp:339
unsigned long getMaxNumCores() const
Get the maximum number of cores that the task can use.
Definition: WorkflowTask.cpp:117
void addOutputFile(WorkflowFile *file)
Add an output file to the task.
Definition: WorkflowTask.cpp:72
unsigned long getMinNumCores() const
Get the minimum number of cores required for running the task.
Definition: WorkflowTask.cpp:108
double getReadInputStartDate()
Get the task's most recent read input start date.
Definition: WorkflowTask.cpp:682
unsigned int getFailureCount()
Get the number of times a task has failed.
Definition: WorkflowTask.cpp:609
void setAverageCPU(double)
Set the task average CPU usage.
Definition: WorkflowTask.cpp:396
std::map< WorkflowFile *, std::pair< std::string, std::string > > getFileTransfers() const
Get a map of src and dst hosts for file transfers (only available for WorkflowTask::TaskType::TRANSFE...
Definition: WorkflowTask.cpp:806
Abstraction of a job used for executing tasks in a Workflow.
Definition: WorkflowJob.h:31
double getWriteOutputEndDate()
Get the task's most recent write output end date.
Definition: WorkflowTask.cpp:706
A data file used/produced by a WorkflowTask in a Workflow.
Definition: WorkflowFile.h:26
void addSrcDest(WorkflowFile *, const std::string &, const std::string &)
Set a pair of src and dest hosts for transfers (it is only meaningful for WorkflowTask::TaskType::TRA...
Definition: WorkflowTask.cpp:818
long getPriority() const
Get the task priority. By default, priority is 0.
Definition: WorkflowTask.cpp:372
WorkflowTask::State getState() const
Get the state of the task.
Definition: WorkflowTask.cpp:171
double getParallelEfficiency() const
Get the parallel efficiency of the task.
Definition: WorkflowTask.cpp:126
unsigned long getNumCoresAllocated()
Returns the number of cores allocated for this task's most recent execution or 0 if an execution atte...
Definition: WorkflowTask.cpp:770
double getFailureDate()
Get the task's most recent failure date.
Definition: WorkflowTask.cpp:714
WorkflowJob * getJob() const
Get the task's containing job.
Definition: WorkflowTask.cpp:331
unsigned long getTopLevel()
Returns the task's top level (max number of hops on a reverse path up to an entry task...
Definition: WorkflowTask.cpp:753
double getFlops() const
Get the number of flops of the task.
Definition: WorkflowTask.cpp:99
int getNumberOfParents() const
Get the number of parents of a task.
Definition: WorkflowTask.cpp:158
double getEndDate()
Get the task's most recent end date.
Definition: WorkflowTask.cpp:658
std::string getID() const
Get the id of the task.
Definition: WorkflowTask.cpp:90
unsigned long getBytesWritten() const
Set the amount of bytes written by the task.
Definition: WorkflowTask.cpp:420
double getComputationStartDate()
Get the tasks's most recent computation start date.
Definition: WorkflowTask.cpp:666
unsigned long getBytesRead() const
Get the amount of bytes read by the task.
Definition: WorkflowTask.cpp:404
std::set< WorkflowFile * > getInputFiles()
Get the set of input WorkflowFile objects for the task.
Definition: WorkflowTask.cpp:624
void setClusterID(std::string)
Set the cluster id for the task.
Definition: WorkflowTask.cpp:348
void addInputFile(WorkflowFile *file)
Add an input file to the task.
Definition: WorkflowTask.cpp:54
double getReadInputEndDate()
Get the task's most recent read input end date.
Definition: WorkflowTask.cpp:690
void setBytesWritten(unsigned long)
Set the amount of bytes written by the task.
Definition: WorkflowTask.cpp:428
double getAverageCPU() const
Get the task average CPU usage.
Definition: WorkflowTask.cpp:388
static std::string stateToString(WorkflowTask::State state)
Convert task state to a string (useful for output, debugging, logging, etc.)
Definition: WorkflowTask.cpp:199
double getWriteOutputStartDate()
Get the task's most recent write output start date.
Definition: WorkflowTask.cpp:698
std::stack< WorkflowTaskExecution > getExecutionHistory()
Get the execution history of this task.
Definition: WorkflowTask.cpp:577
Definition: TerminalOutput.cpp:15
double getTerminationDate()
Get the tasks's most recent termination date (when it was explicitly requested to be terminated by th...
Definition: WorkflowTask.cpp:722
double getStartDate()
Get the task's most recent start date.
Definition: WorkflowTask.cpp:650
void setPriority(long)
Set the task priority.
Definition: WorkflowTask.cpp:380
std::set< WorkflowFile * > getOutputFiles()
Get the set of output WorkflowFile objects for the task.
Definition: WorkflowTask.cpp:637
std::string getExecutionHost()
Returns the name of the host on which the task has most recently been executed, or "" if the task has...
Definition: WorkflowTask.cpp:762