wrench::StandardJob

class StandardJob : public wrench::Job, public std::enable_shared_from_this<StandardJob>

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

Public Types

enum State

Standard job states.

Values:

enumerator NOT_SUBMITTED

Not submitted yet.

enumerator PENDING

Submitted but not running yet.

enumerator RUNNING

Running.

enumerator COMPLETED

Completed successfully.

enumerator FAILED

Failed.

enumerator TERMINATED

Terminated by submitter.

Public Functions

std::map<std::shared_ptr<DataFile>, std::vector<std::shared_ptr<FileLocation>>> getFileLocations() const

Get the file location map for the job.

Returns:

a map of files to storage services

sg_size_t getMinimumRequiredMemory() const

Returns the minimum RAM capacity required to run the job (i.e., at least one task in the job cannot run if less ram than this minimum is available)

Returns:

the number of cores

unsigned long getMinimumRequiredNumCores() const

Returns the minimum number of cores required to run the job (i.e., at least one task in the job cannot run if fewer cores than this minimum are available)

Returns:

the number of cores

unsigned long getNumCompletedTasks() const

Get the number of completed tasks in the job.

Returns:

the number of completed tasks

unsigned long getNumTasks() const

Get the number of tasks in the job.

Returns:

the number of tasks

StandardJob::State getState()

Get the state of the standard job.

Returns:

the state

std::vector<std::shared_ptr<WorkflowTask>> getTasks() const

Get the workflow tasks in the job.

Returns:

a vector of workflow tasks