wrench::Job

class Job

Abstraction of a job used for executing tasks in a Workflow.

Subclassed by wrench::CompoundJob, wrench::PilotJob, wrench::StandardJob

Public Functions

virtual ~Job()

Destructor.

S4U_CommPort *getCallbackCommPort()

Get the job’s “next” callback commport, without popping it.

Returns:

the next callback commport

double getEndDate() const

Get the date at which the job ended (<0 means “never submitted”)

Returns:

the end date

std::string getName()

Get the job’s name.

Returns:

the name as a string

S4U_CommPort *getOriginCallbackCommPort()

Get the “origin” callback commport.

Returns:

the next callback commport

std::shared_ptr<ComputeService> getParentComputeService()

Get the compute service that is running /ran the job.

Returns:

a compute service

double getPriority() const

Get the job’s priority (the higher the priority value, the higher the priority)

Returns:

the job’s priority

std::map<std::string, std::string> &getServiceSpecificArguments()

Return the service-specific arguments that are used during job submission.

Returns:

a map of argument name/values

double getSubmitDate() const

Get the date at which the job was last submitted (<0 means “never submitted”)

Returns:

the submit date

S4U_CommPort *popCallbackCommPort()

Get the “next” callback commport (returns the workflow commport if the commport stack is empty), and pops it.

Returns:

the next callback commport

void printCallbackCommPortStack()

Method to print the call back stack.

void pushCallbackCommPort(S4U_CommPort *commport)

Pushes a callback commport.

Parameters:

commport – the commport name

void setParentComputeService(std::shared_ptr<ComputeService> compute_service)

Set the parent compute service of the job.

Parameters:

compute_service – a compute service

virtual void setPriority(double p)

Set the job’s priority (the higher the priority value, the higher the priority)

Parameters:

p – a priority