public class SeqExec extends Abstract
Modifier and Type | Field and Description |
---|---|
static String |
COLLAPSE_LOGICAL_NAME
The logical name of the transformation that is able to run multiple
jobs sequentially.
|
static String |
EXECUTABLE_BASENAME
The basename of the pegasus cluster executable.
|
private boolean |
mFailOnFirstError
Flag indicating whether to fail on first hard error or not.
|
private boolean |
mGlobalLog
Flag indicating whether a global log file or per job file.
|
private boolean |
mLogProgress
Flag to indicate whether to log progress or not.
|
static String |
SEQEXEC_PROGRESS_REPORT_SUFFIX
The suffix to be applied to seqexec progress report file.
|
CLUSTERED_JOB_PREFIX, DERIVATION_NAMESPACE, DERIVATION_VERSION, mBag, mClusteredADag, mDirectory, mGridStartFactory, mLogger, MONITORD_COMMENT_MARKER, mProps, mSiteStore, mTCHandle, TRANSFORMATION_NAMESPACE, TRANSFORMATION_VERSION
VERSION
Constructor and Description |
---|
SeqExec()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
abortOnFristJobFailure()
Returns a boolean indicating whether to fail the aggregated job on
detecting the first failure during execution of constituent jobs.
|
String |
aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the
AggregatedJob
needs to be invoked with. |
boolean |
entryNotInTC(String site)
Determines whether there is NOT an entry in the transformation catalog
for the job aggregator executable on a particular site.
|
String |
getClusterExecutableBasename()
Returns the executable basename of the clustering executable used.
|
String |
getClusterExecutableLFN()
Returns the logical name of the transformation that is used to
collapse the jobs.
|
void |
initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation
|
protected String |
logFile(AggregatedJob job)
Returns the name of the log file to used on the remote site, for the
seqexec job.
|
void |
makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form.
|
void |
setAbortOnFirstJobFailure(boolean fail)
Setter method to indicate , failure on first consitutent job should
result in the abort of the whole aggregated job.
|
constructAbstractAggregatedJob, constructAbstractAggregatedJob, entryNotInTC, getCommentString, getCompleteTranformationName, getTCEntry, setDirectory
public static final String COLLAPSE_LOGICAL_NAME
public static final String EXECUTABLE_BASENAME
public static final String SEQEXEC_PROGRESS_REPORT_SUFFIX
private boolean mGlobalLog
private boolean mFailOnFirstError
private boolean mLogProgress
public void initialize(ADag dag, PegasusBag bag)
initialize
in interface JobAggregator
initialize
in class Abstract
dag
- the workflow that is being clustered.bag
- the bag of objects that is useful for initialization.public void makeAbstractAggregatedJobConcrete(AggregatedJob job)
makeAbstractAggregatedJobConcrete
in interface JobAggregator
makeAbstractAggregatedJobConcrete
in class Abstract
job
- the abstract clustered jobpublic String getClusterExecutableLFN()
COLLAPSE_LOGICAL_NAME
public String getClusterExecutableBasename()
EXECUTABLE_BASENAME
public boolean entryNotInTC(String site)
site
- the site at which existence check is required.public String aggregatedJobArguments(AggregatedJob job)
AggregatedJob
needs to be invoked with.aggregatedJobArguments
in class Abstract
job
- the AggregatedJob
for which the arguments have
to be constructed.public void setAbortOnFirstJobFailure(boolean fail)
fail
- indicates whether to abort or not .public boolean abortOnFristJobFailure()
protected String logFile(AggregatedJob job)
job
- the AggregatedJob
Copyright © 2011 The University of Southern California. All Rights Reserved.