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

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

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