WorkflowTask.h
268 std::string execution_host; // Host on which the task executed ("" if not executed successfully - yet)
270 State upcoming_visible_state; // A visible state that will become active once a WMS has process a previously sent workflow execution event
278 // std::map<WorkflowFile *, std::pair<std::string, std::string>> fileTransfers; // Map of transfer files and hosts
void setBytesRead(unsigned long)
Set the number of bytes read by the task.
Definition: WorkflowTask.cpp:442
Workflow * getWorkflow() const
Get the workflow that contains the task.
Definition: WorkflowTask.cpp:291
double getComputationEndDate()
Get the task's most recent computation end date.
Definition: WorkflowTask.cpp:682
double task_terminated
Task's terminated time.
Definition: WorkflowTask.h:231
Pending (has been submitted to a compute service)
Definition: WorkflowTask.h:71
double getMemoryRequirement() const
Get the memory requirement of the task.
Definition: WorkflowTask.cpp:163
std::vector< WorkflowTask * > getParents() const
Get the parents of a task.
Definition: WorkflowTask.cpp:208
std::string getClusterID() const
Get the cluster Id for the task.
Definition: WorkflowTask.cpp:385
unsigned long getMaxNumCores() const
Get the maximum number of cores that the task can use.
Definition: WorkflowTask.cpp:145
void setReadInputStartDate(double date)
Set the date when the read input portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:521
void setStartDate(double date)
Set the task's start date.
Definition: WorkflowTask.cpp:467
void addOutputFile(WorkflowFile *file)
Add an output file to the task.
Definition: WorkflowTask.cpp:86
void incrementFailureCount()
Increment the failure count of a task.
Definition: WorkflowTask.cpp:624
unsigned long getMinNumCores() const
Get the minimum number of cores required for running the task.
Definition: WorkflowTask.cpp:136
void setTerminationDate(double date)
Set the date when the task was terminated.
Definition: WorkflowTask.cpp:594
void setNumCoresAllocated(unsigned long num_cores)
Sets the number of cores allocated for this task.
Definition: WorkflowTask.cpp:800
double write_output_start
Task's write output start time.
Definition: WorkflowTask.h:223
void setInternalState(WorkflowTask::InternalState)
Set the internal state of the task.
Definition: WorkflowTask.cpp:300
void setComputationStartDate(double date)
Set the date when the computation portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:491
double getReadInputStartDate()
Get the task's most recent read input start date.
Definition: WorkflowTask.cpp:690
unsigned int getFailureCount()
Get the number of times a task has failed.
Definition: WorkflowTask.cpp:617
std::vector< WorkflowTask * > getChildren() const
Get the children of a task.
Definition: WorkflowTask.cpp:186
void setAverageCPU(double)
Set the task average CPU usage.
Definition: WorkflowTask.cpp:426
void setExecutionHost(std::string hostname)
Sets the host on which this task is running.
Definition: WorkflowTask.cpp:787
void setWriteOutputStartDate(double date)
Set the date when the write output portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:551
double read_input_end
Task's read input end time.
Definition: WorkflowTask.h:217
Abstraction of a job used for executing tasks in a Workflow.
Definition: WorkflowJob.h:34
void setFailureDate(double date)
Set the date when the task has failed.
Definition: WorkflowTask.cpp:580
double getWriteOutputEndDate()
Get the task's most recent write output end date.
Definition: WorkflowTask.cpp:714
A data file used/produced by a WorkflowTask in a Workflow.
Definition: WorkflowFile.h:26
double task_end
Task's end time.
Definition: WorkflowTask.h:227
void setWriteOutputEndDate(double date)
Set the date when the write output portion of a WorkflowTask has completed.
Definition: WorkflowTask.cpp:566
WorkflowTask::State getState() const
Get the state of the task.
Definition: WorkflowTask.cpp:217
double getParallelEfficiency() const
Get the parallel efficiency of the task.
Definition: WorkflowTask.cpp:154
double task_failed
Task's failed time.
Definition: WorkflowTask.h:229
double read_input_start
Task's read input start time.
Definition: WorkflowTask.h:215
WorkflowTask::InternalState getInternalState() const
Get the state of the task (as known to the "internal" layer)
Definition: WorkflowTask.cpp:236
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:778
A data structure that keeps track of a task's execution event times.
Definition: WorkflowTask.h:211
double getFailureDate()
Get the task's most recent failure date.
Definition: WorkflowTask.cpp:722
WorkflowJob * getJob() const
Get the task's containing job.
Definition: WorkflowTask.cpp:377
double computation_start
Task's computation start time.
Definition: WorkflowTask.h:219
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:761
void setComputationEndDate(double date)
Set the date when the computation portion of a WorkflowTask has ended.
Definition: WorkflowTask.cpp:506
double computation_end
Task's computation end time.
Definition: WorkflowTask.h:221
double getFlops() const
Get the number of flops of the task.
Definition: WorkflowTask.cpp:127
void setEndDate(double date)
Set the task's end date.
Definition: WorkflowTask.cpp:477
unsigned long num_cores_allocated
Task's number of allocated cores.
Definition: WorkflowTask.h:236
unsigned long getNumberOfParents() const
Get the number of parents of a task.
Definition: WorkflowTask.cpp:195
WorkflowTask::State getUpcomingState() const
Get the state of the task.
Definition: WorkflowTask.cpp:226
WorkflowTaskExecution(double task_start)
Constructor.
Definition: WorkflowTask.h:243
double getEndDate()
Get the task's most recent end date.
Definition: WorkflowTask.cpp:666
std::string getID() const
Get the id of the task.
Definition: WorkflowTask.cpp:118
unsigned long getBytesWritten() const
Get the number of bytes written by the task.
Definition: WorkflowTask.cpp:450
double getComputationStartDate()
Get the tasks's most recent computation start date.
Definition: WorkflowTask.cpp:674
unsigned long getBytesRead() const
Get the number of bytes read by the task.
Definition: WorkflowTask.cpp:434
void setReadInputEndDate(double date)
Set the date when the read input portion of a WorkflowTask has completed.
Definition: WorkflowTask.cpp:536
std::set< WorkflowFile * > getInputFiles()
Get the set of input WorkflowFile objects for the task.
Definition: WorkflowTask.cpp:632
void setClusterID(std::string)
Set the cluster id for the task.
Definition: WorkflowTask.cpp:394
unsigned long updateTopLevel()
Update the task's top level (looking only at the parents, and updating children)
Definition: WorkflowTask.cpp:738
unsigned long getNumberOfChildren() const
Get the number of children of a task.
Definition: WorkflowTask.cpp:173
void addInputFile(WorkflowFile *file)
Add an input file to the task.
Definition: WorkflowTask.cpp:56
void setState(WorkflowTask::State)
Set the visible state of the task.
Definition: WorkflowTask.cpp:310
unsigned long getPriority() const
Get the task priority. By default, priority is 0.
Definition: WorkflowTask.cpp:402
double getReadInputEndDate()
Get the task's most recent read input end date.
Definition: WorkflowTask.cpp:698
void setBytesWritten(unsigned long)
Set the number of bytes written by the task.
Definition: WorkflowTask.cpp:458
void setJob(WorkflowJob *job)
Set the task's containing job.
Definition: WorkflowTask.cpp:369
double getAverageCPU() const
Get the task average CPU usage.
Definition: WorkflowTask.cpp:418
static std::string stateToString(WorkflowTask::State state)
Convert task state to a string (useful for output, debugging, logging, etc.)
Definition: WorkflowTask.cpp:245
void setUpcomingState(WorkflowTask::State)
Set the upcoming visible state of the task.
Definition: WorkflowTask.cpp:360
std::string execution_host
Task's execution host.
Definition: WorkflowTask.h:234
double getWriteOutputStartDate()
Get the task's most recent write output start date.
Definition: WorkflowTask.cpp:706
std::stack< WorkflowTaskExecution > getExecutionHistory()
Get the execution history of this task.
Definition: WorkflowTask.cpp:608
Definition: Alarm.cpp:19
double getTerminationDate()
Get the tasks's most recent termination date (when it was explicitly requested to be terminated by th...
Definition: WorkflowTask.cpp:730
double getStartDate()
Get the task's most recent start date.
Definition: WorkflowTask.cpp:658
void setPriority(long)
Set the task priority.
Definition: WorkflowTask.cpp:410
double task_start
Task's start time.
Definition: WorkflowTask.h:213
std::set< WorkflowFile * > getOutputFiles()
Get the set of output WorkflowFile objects for the task.
Definition: WorkflowTask.cpp:645
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:770
double write_output_end
Task's write output end time.
Definition: WorkflowTask.h:225