Package edu.isi.pegasus.planner.classes
Class DAGJob
- java.lang.Object
-
- edu.isi.pegasus.planner.classes.Data
-
- edu.isi.pegasus.planner.classes.Job
-
- edu.isi.pegasus.planner.classes.DAGJob
-
- All Implemented Interfaces:
GraphNodeContent
,java.lang.Cloneable
public class DAGJob extends Job
This is a data class that stores the contents of the DAG job in a DAX conforming to schema 3.0 or higher.- Version:
- $Revision$
- Author:
- Karan Vahi
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
JOB_PREFIX
The prefix to be attached for the DAX jobsprivate java.lang.String
mDAGFile
The DAG File that the job refers to.private java.lang.String
mDAGLFN
The DAG LFN.private java.lang.String
mDirectory
The directory in which the DAG needs to execute.-
Fields inherited from class edu.isi.pegasus.planner.classes.Job
CHMOD_JOB, CLEANUP_JOB, COMPUTE_JOB, condorUniverse, condorVariables, CREATE_DIR_JOB, DAG_JOB, dagmanVariables, DAX_JOB, dvName, dvNamespace, dvVersion, envVariables, executable, executionPool, globusRSL, globusScheduler, hints, inputFiles, INTER_POOL_JOB, jobClass, jobID, jobName, level, logicalId, logicalName, namespace, outputFiles, REPLICA_REG_JOB, STAGE_IN_JOB, STAGE_IN_WORKER_PACKAGE_JOB, STAGE_OUT_JOB, stdErr, stdIn, stdOut, strargs, UNASSIGNED_JOB, vdsNS, version
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
clone()
Returns a new copy of the Object.java.lang.String
generateName(java.lang.String prefix)
Generates a name for the job that serves as the primary id for the jobjava.lang.String
getDAGFile()
Returns the DAGFile the job refers to.java.lang.String
getDAGLFN()
Returns the lfn for the DAGFile the job refers to.java.lang.String
getDirectory()
Returns the directory the job refers to.void
setDAGFile(java.lang.String file)
Sets the DAG filevoid
setDAGLFN(java.lang.String lfn)
Sets the DAG file LFNvoid
setDirectory(java.lang.String directory)
Sets the directory in which the dag needs to execute.java.lang.String
toString()
Returns a textual description of the DAG Job.-
Methods inherited from class edu.isi.pegasus.planner.classes.Job
addCredentialType, addCredentialType, addInputFile, addNotification, addNotifications, addNotifications, addOutputFile, addProfile, computeRuntime, equals, getArguments, getCompleteDVName, getCompleteTCName, getCredentialTypes, getDAXID, getDOTColor, getDVName, getDVNamespace, getDVVersion, getGridGatewayJobType, getID, getInputFiles, getJobManager, getJobType, getJobTypeDescription, getJobTypeDescription, getLevel, getLogicalID, getName, getNotifications, getNotifications, getOutputFiles, getPreScriptArguments, getPreScriptPath, getRemoteExecutable, getRuntime, getSiteHandle, getStagedExecutableBaseName, getStagedExecutableBaseName, getStagingSiteHandle, getStdErr, getStdIn, getStdOut, getSubmissionCredential, getTXName, getTXNamespace, getTXVersion, getUniverse, getVDSSuperNode, isMPIJob, mergeProfiles, requiresCredentials, resetCredentialTypes, resetNotifications, resetProfiles, runInWorkDirectory, setArguments, setDerivation, setDVName, setDVNamespace, setDVVersion, setExecutableStagingForJob, setInputFiles, setJobManager, setJobType, setLevel, setLogicalID, setName, setOutputFiles, setPreScript, setPreScript, setRemoteExecutable, setRuntime, setRuntime, setSiteHandle, setStagingSiteHandle, setStdErr, setStdIn, setStdOut, setSubmissionCredential, setTransformation, setTXName, setTXNamespace, setTXVersion, setTypeRecursive, setUniverse, setVDSSuperNode, toDOT, toDOT, typeInRange, typeRecursive, updateProfiles, updateProfiles, updateProfiles, updateProfiles, userExecutablesStagedForJob
-
Methods inherited from class edu.isi.pegasus.planner.classes.Data
setToString, vectorToString
-
-
-
-
Field Detail
-
JOB_PREFIX
public static final java.lang.String JOB_PREFIX
The prefix to be attached for the DAX jobs- See Also:
- Constant Field Values
-
mDAGLFN
private java.lang.String mDAGLFN
The DAG LFN.
-
mDAGFile
private java.lang.String mDAGFile
The DAG File that the job refers to.
-
mDirectory
private java.lang.String mDirectory
The directory in which the DAG needs to execute.
-
-
Constructor Detail
-
DAGJob
public DAGJob()
The default constructor.
-
DAGJob
public DAGJob(Job job)
The overloaded construct that constructs a DAG job by wrapping around theJob
job.- Parameters:
job
- the original job description.
-
-
Method Detail
-
setDAGLFN
public void setDAGLFN(java.lang.String lfn)
Sets the DAG file LFN- Parameters:
lfn
- the LFN of the DAG file.
-
getDAGLFN
public java.lang.String getDAGLFN()
Returns the lfn for the DAGFile the job refers to.- Returns:
- the lfn
-
setDAGFile
public void setDAGFile(java.lang.String file)
Sets the DAG file- Parameters:
file
- the path to the DAG file.
-
getDAGFile
public java.lang.String getDAGFile()
Returns the DAGFile the job refers to.- Returns:
- dag file
-
setDirectory
public void setDirectory(java.lang.String directory)
Sets the directory in which the dag needs to execute.- Overrides:
setDirectory
in classJob
- Parameters:
directory
- the directory where dag needs to execute
-
getDirectory
public java.lang.String getDirectory()
Returns the directory the job refers to.- Overrides:
getDirectory
in classJob
- Returns:
- the directory.
-
generateName
public java.lang.String generateName(java.lang.String prefix)
Generates a name for the job that serves as the primary id for the job- Parameters:
prefix
- any prefix that needs to be applied while constructing the job name- Returns:
- the id for the job
-
toString
public java.lang.String toString()
Returns a textual description of the DAG Job.
-
-