Merge pull request #423 from broadinstitute/jt_pdexheimer_patch

Changed name of jobs submitted to cluster job runners
This commit is contained in:
jmthibault79 2013-11-13 04:38:00 -08:00
commit 34c8ad529f
3 changed files with 7 additions and 2 deletions

View File

@ -50,7 +50,7 @@ class DrmaaJobRunner(val session: Session, val function: CommandLineFunction) ex
session.synchronized {
val drmaaJob: JobTemplate = session.createJobTemplate
drmaaJob.setJobName(function.description.take(jobNameLength).replaceAll(jobNameFilter, "_"))
drmaaJob.setJobName(function.jobRunnerJobName.take(jobNameLength).replaceAll(jobNameFilter, "_"))
// Set the current working directory
drmaaJob.setWorkingDirectory(function.commandDirectory.getPath)

View File

@ -71,7 +71,7 @@ class Lsf706JobRunner(val function: CommandLineFunction) extends CommandLineJobR
for (i <- 0 until LibLsf.LSF_RLIM_NLIMITS)
request.rLimits(i) = LibLsf.DEFAULT_RLIMIT;
request.jobName = function.description.take(LibBat.MAX_JOB_NAME_LEN)
request.jobName = function.jobRunnerJobName.take(LibBat.MAX_JOB_NAME_LEN)
request.options |= LibBat.SUB_JOB_NAME
// Set the output file for stdout

View File

@ -150,6 +150,11 @@ trait QFunction extends Logging with QJobReport {
case _ => analysisName
}
}
/**
* The name of the job as submitted to the job runner
*/
def jobRunnerJobName = shortDescription
/**
* Returns true if the function is done.