zzh
/
gatk-3.8
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added a QFunction.jobLimitSeconds for experimentation, currently only used as the equivalent of bsub -W. 

git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@5002 348d0f76-0448-11de-a6fe-93d51630548a
This commit is contained in:
kshakir 2011-01-14 19:45:03 +00:00
parent af31d02a2d
commit 2355a55067
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
scala/src/org/broadinstitute/sting/queue/engine/Lsf706JobRunner.scala
View File

@ -63,6 +63,10 @@ class Lsf706JobRunner(function: CommandLineFunction) extends LsfJobRunner(functi
request.options |= LibBat.SUB_JOB_NAME request.options |= LibBat.SUB_JOB_NAME
} }
if (function.jobLimitSeconds.isDefined) {
request.rLimits(LibLsf.LSF_RLIMIT_RUN) = function.jobLimitSeconds.get
}
writeExec() writeExec()
request.command = "sh " + exec request.command = "sh " + exec

7
scala/src/org/broadinstitute/sting/queue/function/QFunction.scala
View File

@ -37,6 +37,13 @@ trait QFunction extends Logging {
/** Order the function was added to the graph. */ /** Order the function was added to the graph. */
var addOrder: List[Int] = Nil var addOrder: List[Int] = Nil
/**
* EXPERIMENTAL AND NOT SUPPORTED!!
* Limits the number of seconds that the job will run.
* TODO: Replace with full resource specifications.
*/
var jobLimitSeconds: Option[Int] = None
/** /**
* A callback for modifying the run. * A callback for modifying the run.
* NOTE: This function is for ADVANCED use only and is unsupported. * NOTE: This function is for ADVANCED use only and is unsupported.