Class Condor
- java.lang.Object
-
- edu.isi.pegasus.planner.code.generator.condor.style.Abstract
-
- edu.isi.pegasus.planner.code.generator.condor.style.Condor
-
- All Implemented Interfaces:
CondorStyle
- Direct Known Subclasses:
CondorC
,CondorGlideinWMS
public class Condor extends Abstract
Enables a job to be directly submitted to the condor pool of which the submit host is a part of. This style is applied for jobs to be run - on the submit host in the scheduler universe (local pool execution) - on the local condor pool of which the submit host is a part of- Version:
- $Revision$
- Author:
- Karan Vahi
-
-
Field Summary
Fields Modifier and Type Field 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 notstatic 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 notstatic java.lang.String
PEGASUS_INITIAL_DIR_KEY
The name of the environment variable for the initial dir for pegasus lite localstatic 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 filesstatic java.lang.String
PEGASUS_TRANSFER_OUTPUT_FILES_KEY
The name of the environment variable for transferring output filesstatic 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
-
Fields inherited from class edu.isi.pegasus.planner.code.generator.condor.style.Abstract
mCredentialFactory, mLogger, mProps, mSiteStore
-
Fields inherited from interface edu.isi.pegasus.planner.code.generator.condor.CondorStyle
VERSION
-
-
Constructor Summary
Constructors Constructor Description Condor()
The default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
apply(Job job)
Applies the condor style to the job.protected java.lang.String
getSubmitHostPathToPegasusLiteLocal()
Determines the path to PegasusLite local jobvoid
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-
Methods inherited from class edu.isi.pegasus.planner.code.generator.condor.style.Abstract
apply, applyCredentialsForJobSubmission, applyCredentialsForLocalExec, applyCredentialsForRemoteExec, complainForCredential, errorMessage
-
-
-
-
Field Detail
-
UNIVERSE_KEY
public static final java.lang.String UNIVERSE_KEY
- See Also:
- Constant Field Values
-
VANILLA_UNIVERSE
public static final java.lang.String VANILLA_UNIVERSE
- See Also:
- Constant Field Values
-
SCHEDULER_UNIVERSE
public static final java.lang.String SCHEDULER_UNIVERSE
- See Also:
- Constant Field Values
-
STANDARD_UNIVERSE
public static final java.lang.String STANDARD_UNIVERSE
- See Also:
- Constant Field Values
-
LOCAL_UNIVERSE
public static final java.lang.String LOCAL_UNIVERSE
- See Also:
- Constant Field Values
-
PARALLEL_UNIVERSE
public static final java.lang.String PARALLEL_UNIVERSE
- See Also:
- Constant Field Values
-
TRANSFER_EXECUTABLE_KEY
public static final java.lang.String TRANSFER_EXECUTABLE_KEY
- See Also:
- Constant Field Values
-
STYLE_NAME
public static final java.lang.String STYLE_NAME
The name of the style being implemented.- See Also:
- Constant Field Values
-
PEGASUS_LITE_LOCAL_FILE_BASENAME
public static final java.lang.String PEGASUS_LITE_LOCAL_FILE_BASENAME
The Pegasus Lite local wrapper basename.- See Also:
- Constant Field Values
-
PEGASUS_TRANSFER_INPUT_FILES_KEY
public static final java.lang.String PEGASUS_TRANSFER_INPUT_FILES_KEY
The name of the environment variable for transferring input files- See Also:
- Constant Field Values
-
PEGASUS_TRANSFER_OUTPUT_FILES_KEY
public static final java.lang.String PEGASUS_TRANSFER_OUTPUT_FILES_KEY
The name of the environment variable for transferring output files- See Also:
- Constant Field Values
-
PEGASUS_INITIAL_DIR_KEY
public static final java.lang.String PEGASUS_INITIAL_DIR_KEY
The name of the environment variable for the initial dir for pegasus lite local- See Also:
- Constant Field Values
-
PEGASUS_EXECUTE_IN_INITIAL_DIR
public static final 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- See Also:
- Constant Field Values
-
PEGASUS_CONNECT_STDIN_KEY
public static final java.lang.String PEGASUS_CONNECT_STDIN_KEY
Whether to connect stdin or not- See Also:
- Constant Field Values
-
mPegasusLiteEnabled
private boolean mPegasusLiteEnabled
A boolean indicating whether pegasus lite mode is picked up or not.
-
mPegasusLiteLocalWrapper
private java.lang.String mPegasusLiteLocalWrapper
Path to Pegasus Lite local wrapper script.
-
-
Method Detail
-
initialize
public void initialize(PegasusBag bag, CredentialHandlerFactory credentialFactory) throws CondorStyleException
Initializes the Code Style implementation.- Specified by:
initialize
in interfaceCondorStyle
- Overrides:
initialize
in classAbstract
- Parameters:
bag
- the bag of initialization objectscredentialFactory
- the credential handler factory- Throws:
CondorStyleFactoryException
- that nests any error that might occur during the instantiation of the implementation.CondorStyleException
-
apply
public void apply(Job job) throws CondorStyleException
Applies the condor style to the job. Changes the job so that it results in generation of a condor style submit file that can be directly submitted to the underlying condor scheduler on the submit host, without going through CondorG. This applies to the case of - local site execution - submitting directly to the condor pool of which the submit host is a part of.- Parameters:
job
- the job on which the style needs to be applied.- Throws:
CondorStyleException
- in case of any error occuring code generation.
-
wrapJobWithLocalPegasusLite
private void wrapJobWithLocalPegasusLite(Job job) throws CondorStyleException
Wraps the local universe jobs with a local Pegasus Lite wrapper to get around the Condor file IO bug for local universe job- Parameters:
job
- the job that needs to be wrapped.- Throws:
CondorStyleException
-
getSubmitHostPathToPegasusLiteLocal
protected java.lang.String getSubmitHostPathToPegasusLiteLocal()
Determines the path to PegasusLite local job- Returns:
- the path on the submit host.
-
-