WorkflowJob.h
std::map< std::string, std::string > getServiceSpecificArguments()
Return the service-specific arguments that were used during job submission.
Definition: WorkflowJob.cpp:165
A pilot job that can be submitted to a ComputeService and that, once started, will act as a ComputeSe...
Definition: WorkflowJob.h:40
ComputeService * getParentComputeService()
Get the parent compute service of the job.
Definition: WorkflowJob.cpp:149
std::stack< std::string > callback_mailbox_stack
Stack of callback mailboxes (to pop notifications)
Definition: WorkflowJob.h:83
unsigned long getNewUniqueNumber()
Generate a unique number (for each newly generated job)
Definition: WorkflowJob.cpp:131
std::string popCallbackMailbox()
Get the "next" callback mailbox (returns the workflow mailbox if the mailbox stack is empty)...
Definition: WorkflowJob.cpp:108
ComputeService * parent_compute_service
The compute service to which the job was submitted.
Definition: WorkflowJob.h:93
std::string getOriginCallbackMailbox()
Get the "origin" callback mailbox.
Definition: WorkflowJob.cpp:96
std::map< std::string, std::string > service_specific_args
Service-specific arguments used during job submission.
Definition: WorkflowJob.h:80
Abstraction of a job used for executing tasks in a Workflow.
Definition: WorkflowJob.h:31
A standard job that can be submitted directly to a ComputeService for execution.
Definition: WorkflowJob.h:37
std::string getCallbackMailbox()
Get the "next" callback mailbox (returns the origin (i.e., workflow) mailbox if the mailbox stack is ...
Definition: WorkflowJob.cpp:84
Workflow * workflow
The workflow this job belong to.
Definition: WorkflowJob.h:85
std::string getName()
Get the job's name.
Definition: WorkflowJob.cpp:74
double submit_date
The date at which the job was last submitted.
Definition: WorkflowJob.h:91
std::string getTypeAsString()
Get the job type name.
Definition: WorkflowJob.cpp:54
void pushCallbackMailbox(std::string)
Pushes a callback mailbox.
Definition: WorkflowJob.cpp:122
A helper daemon (co-located with and explicitly started by a WMS), which is used to handle all job ex...
Definition: JobManager.h:40
double getSubmitDate()
Get the date at which the job was last submitted (<0 means "never submitted")
Definition: WorkflowJob.cpp:157
void setParentComputeService(ComputeService *compute_service)
Set the parent compute service of the job.
Definition: WorkflowJob.cpp:140
Definition: TerminalOutput.cpp:15