public class Condor extends Abstract
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
LOCAL_UNIVERSE |
private boolean |
mPegasusLiteEnabled
A boolean indicating whether pegasus lite mode is picked up or not.
|
private java.lang.String |
mPegasusLiteLocalWrapper
Path to Pegasus Lite local wrapper script.
|
static java.lang.String |
PARALLEL_UNIVERSE |
static java.lang.String |
PEGASUS_CONNECT_STDIN_KEY
Whether to connect stdin or not
|
static java.lang.String |
PEGASUS_EXECUTE_IN_INITIAL_DIR
The name of the environment variable that determines if job should be executed in initial dir or not
|
static java.lang.String |
PEGASUS_INITIAL_DIR_KEY
The name of the environment variable for the initial dir for pegasus lite local
|
static java.lang.String |
PEGASUS_LITE_LOCAL_FILE_BASENAME
The Pegasus Lite local wrapper basename.
|
static java.lang.String |
PEGASUS_TRANSFER_INPUT_FILES_KEY
The name of the environment variable for transferring input files
|
static java.lang.String |
PEGASUS_TRANSFER_OUTPUT_FILES_KEY
The name of the environment variable for transferring output files
|
static java.lang.String |
SCHEDULER_UNIVERSE |
static java.lang.String |
STANDARD_UNIVERSE |
static java.lang.String |
STYLE_NAME
The name of the style being implemented.
|
static java.lang.String |
TRANSFER_EXECUTABLE_KEY |
static java.lang.String |
UNIVERSE_KEY |
static java.lang.String |
VANILLA_UNIVERSE |
mCredentialFactory, mLogger, mProps, mSiteStore
VERSION
Constructor and Description |
---|
Condor()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
apply(Job job)
Applies the condor style to the job.
|
protected java.lang.String |
getSubmitHostPathToPegasusLiteLocal()
Determines the path to PegasusLite local job
|
void |
initialize(PegasusBag bag,
CredentialHandlerFactory credentialFactory)
Initializes the Code Style implementation.
|
private void |
wrapJobWithLocalPegasusLite(Job job)
Wraps the local universe jobs with a local Pegasus Lite wrapper to get
around the Condor file IO bug for local universe job
|
apply, applyCredentialsForJobSubmission, applyCredentialsForLocalExec, applyCredentialsForRemoteExec, complainForCredential, errorMessage
public static final java.lang.String UNIVERSE_KEY
public static final java.lang.String VANILLA_UNIVERSE
public static final java.lang.String SCHEDULER_UNIVERSE
public static final java.lang.String STANDARD_UNIVERSE
public static final java.lang.String LOCAL_UNIVERSE
public static final java.lang.String PARALLEL_UNIVERSE
public static final java.lang.String TRANSFER_EXECUTABLE_KEY
public static final java.lang.String STYLE_NAME
public static final java.lang.String PEGASUS_LITE_LOCAL_FILE_BASENAME
public static final java.lang.String PEGASUS_TRANSFER_INPUT_FILES_KEY
public static final java.lang.String PEGASUS_TRANSFER_OUTPUT_FILES_KEY
public static final java.lang.String PEGASUS_INITIAL_DIR_KEY
public static final java.lang.String PEGASUS_EXECUTE_IN_INITIAL_DIR
public static final java.lang.String PEGASUS_CONNECT_STDIN_KEY
private boolean mPegasusLiteEnabled
private java.lang.String mPegasusLiteLocalWrapper
public void initialize(PegasusBag bag, CredentialHandlerFactory credentialFactory) throws CondorStyleException
initialize
in interface CondorStyle
initialize
in class Abstract
bag
- the bag of initialization objectscredentialFactory
- the credential handler factoryCondorStyleFactoryException
- that nests any error that
might occur during the instantiation of the implementation.CondorStyleException
public void apply(Job job) throws CondorStyleException
job
- the job on which the style needs to be applied.CondorStyleException
- in case of any error occuring code generation.private void wrapJobWithLocalPegasusLite(Job job) throws CondorStyleException
job
- the job that needs to be wrapped.CondorStyleException
protected java.lang.String getSubmitHostPathToPegasusLiteLocal()