Package edu.isi.pegasus.planner.code.generator.condor.style

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 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

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

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 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

Methods inherited from class edu.isi.pegasus.planner.code.generator.condor.style.Abstract

apply, applyCredentialsForJobSubmission, applyCredentialsForLocalExec, applyCredentialsForRemoteExec, complainForCredential, errorMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.

Constructor Detail

Condor

public Condor()

The default constructor.

Method Detail

initialize

public void initialize(PegasusBag bag,
                       CredentialHandlerFactory credentialFactory)
                throws CondorStyleException

Initializes the Code Style implementation.

Specified by:

initialize in interface CondorStyle

Overrides:

initialize in class Abstract

Parameters:

bag - the bag of initialization objects

credentialFactory - 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.