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 setReadInputStartDate(double date)
Set the date when the read input portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:491
void setStartDate(double date)
Set the task's start date.
Definition: WorkflowTask.cpp:437
void addOutputFile(WorkflowFile *file)
Add an output file to the task.
Definition: WorkflowTask.cpp:72
void incrementFailureCount()
Increment the failure count of a task.
Definition: WorkflowTask.cpp:616
unsigned long getMinNumCores() const
Get the minimum number of cores required for running the task.
Definition: WorkflowTask.cpp:108
void setTerminationDate(double date)
Set the date when the task was terminated.
Definition: WorkflowTask.cpp:563
void setNumCoresAllocated(unsigned long num_cores)
Sets the number of cores allocated for this task.
Definition: WorkflowTask.cpp:792
void setInternalState(WorkflowTask::InternalState)
Set the internal state of the task.
Definition: WorkflowTask.cpp:254
void setComputationStartDate(double date)
Set the date when the computation portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:461
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
void setExecutionHost(std::string hostname)
Sets the host on which this task is running.
Definition: WorkflowTask.cpp:779
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
void setWriteOutputStartDate(double date)
Set the date when the write output portion of a WorkflowTask has begun.
Definition: WorkflowTask.cpp:521
Abstraction of a job used for executing tasks in a Workflow.
Definition: WorkflowJob.h:31
void setFailureDate(double date)
Set the date when the task has failed.
Definition: WorkflowTask.cpp:550
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
void setWriteOutputEndDate(double date)
Set the date when the write output portion of a WorkflowTask has completed.
Definition: WorkflowTask.cpp:536
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
WorkflowTask::InternalState getInternalState() const
Get the state of the task (as known to the "internal" layer)
Definition: WorkflowTask.cpp:190
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
Definition: WorkflowTask.h:206
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
void setComputationEndDate(double date)
Set the date when the computation portion of a WorkflowTask has ended.
Definition: WorkflowTask.cpp:476
double getFlops() const
Get the number of flops of the task.
Definition: WorkflowTask.cpp:99
void setEndDate(double date)
Set the task's end date.
Definition: WorkflowTask.cpp:447
int getNumberOfParents() const
Get the number of parents of a task.
Definition: WorkflowTask.cpp:158
WorkflowTask::State getUpcomingState() const
Get the state of the task.
Definition: WorkflowTask.cpp:180
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
void setReadInputEndDate(double date)
Set the date when the read input portion of a WorkflowTask has completed.
Definition: WorkflowTask.cpp:506
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
unsigned long updateTopLevel()
Update the task's top level (looking only at the parents, and updating children)
Definition: WorkflowTask.cpp:730
void addInputFile(WorkflowFile *file)
Add an input file to the task.
Definition: WorkflowTask.cpp:54
void setState(WorkflowTask::State)
Set the visible state of the task.
Definition: WorkflowTask.cpp:264
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
void setJob(WorkflowJob *job)
Set the task's containing job.
Definition: WorkflowTask.cpp:323
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
void setUpcomingState(WorkflowTask::State)
Set the upcoming visible state of the task.
Definition: WorkflowTask.cpp:314
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