wrench::PilotJob Class Reference

A pilot (i.e., non-standard) workflow job that can be submitted to a ComputeService by a WMS (via a JobManager) More...

#include <PilotJob.h>

Inheritance diagram for wrench::PilotJob:
wrench::WorkflowJob

Public Types

enum  State {
  NOT_SUBMITTED, PENDING, RUNNING, EXPIRED,
  FAILED, TERMINATED
}
 Pilot job states. More...
 
- Public Types inherited from wrench::WorkflowJob
enum  Type { STANDARD, PILOT }
 Job types. More...
 

Public Member Functions

ComputeServicegetComputeService ()
 Get the compute service provided by the (running) pilot job. More...
 
PilotJob::State getState ()
 Get the state of the pilot job. More...
 
void setComputeService (std::shared_ptr< ComputeService > cs)
 Set the compute service on which the pilot job is running. More...
 
- Public Member Functions inherited from wrench::WorkflowJob
virtual ~WorkflowJob ()
 Destructor.
 
std::string getCallbackMailbox ()
 Get the "next" callback mailbox (returns the origin (i.e., workflow) mailbox if the mailbox stack is empty) More...
 
std::string getName ()
 Get the job's name. More...
 
std::string getOriginCallbackMailbox ()
 Get the "origin" callback mailbox. More...
 
ComputeServicegetParentComputeService ()
 Get the parent compute service of the job. More...
 
std::map< std::string, std::string > getServiceSpecificArguments ()
 Return the service-specific arguments that were used during job submission. More...
 
double getSubmitDate ()
 Get the date at which the job was last submitted (<0 means "never submitted") More...
 
Type getType ()
 Get the job type. More...
 
std::string getTypeAsString ()
 Get the job type name. More...
 
std::string popCallbackMailbox ()
 Get the "next" callback mailbox (returns the workflow mailbox if the mailbox stack is empty), and pops it. More...
 
void pushCallbackMailbox (std::string)
 Pushes a callback mailbox. More...
 
void setParentComputeService (ComputeService *compute_service)
 Set the parent compute service of the job. More...
 

Additional Inherited Members

- Protected Member Functions inherited from wrench::WorkflowJob
 WorkflowJob (Type type)
 Constructor. More...
 
unsigned long getNewUniqueNumber ()
 Generate a unique number (for each newly generated job) More...
 
- Protected Attributes inherited from wrench::WorkflowJob
std::stack< std::string > callback_mailbox_stack
 Stack of callback mailboxes (to pop notifications)
 
std::string name
 The job's name.
 
ComputeServiceparent_compute_service
 The compute service to which the job was submitted.
 
std::map< std::string, std::string > service_specific_args
 Service-specific arguments used during job submission.
 
double submit_date
 The date at which the job was last submitted.
 
Type type
 The job's type.
 
Workflowworkflow
 The workflow this job belong to.
 

Detailed Description

A pilot (i.e., non-standard) workflow job that can be submitted to a ComputeService by a WMS (via a JobManager)

Member Enumeration Documentation

◆ State

Pilot job states.

Enumerator
NOT_SUBMITTED 

Not submitted yet.

PENDING 

Submitted but not running.

RUNNING 

Running.

EXPIRED 

Expired due to a time-to-live limit.

FAILED 

Failed.

TERMINATED 

Terminated by submitter.

Member Function Documentation

◆ getComputeService()

ComputeService * wrench::PilotJob::getComputeService ( )

Get the compute service provided by the (running) pilot job.

Returns
a compute service

◆ getState()

PilotJob::State wrench::PilotJob::getState ( )

Get the state of the pilot job.

Returns
the state

◆ setComputeService()

void wrench::PilotJob::setComputeService ( std::shared_ptr< ComputeService cs)

Set the compute service on which the pilot job is running.

Parameters
csa compute service

The documentation for this class was generated from the following files:
  • /Users/rafsilva/Documents/isi/workspace/wrench/wrench/include/wrench/workflow/job/PilotJob.h
  • /Users/rafsilva/Documents/isi/workspace/wrench/wrench/src/wrench/workflow/job/PilotJob.cpp