Using job ids instead of job names for LSF dependency tracking.
git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@4071 348d0f76-0448-11de-a6fe-93d51630548a
This commit is contained in:
parent
fa36731faf
commit
51678d48e4
|
|
@ -67,10 +67,10 @@ class LsfJobRunner extends DispatchJobRunner with Logging {
|
||||||
* @return The dependency expression for the prior jobs.
|
* @return The dependency expression for the prior jobs.
|
||||||
*/
|
*/
|
||||||
private def dependencyExpression(jobs: Iterable[LsfJob], runOnSuccess: Boolean) = {
|
private def dependencyExpression(jobs: Iterable[LsfJob], runOnSuccess: Boolean) = {
|
||||||
val jobNames = jobs.toSet[LsfJob].map(_.name)
|
val jobIds = jobs.toSet[LsfJob].map(_.bsubJobId)
|
||||||
if (runOnSuccess)
|
if (runOnSuccess)
|
||||||
jobNames.mkString("done(\"", "\") && done(\"", "\")")
|
jobIds.mkString("done(", ") && done(", ")")
|
||||||
else
|
else
|
||||||
jobNames.mkString("ended(\"", "\") && ended(\"", "\")")
|
jobIds.mkString("ended(", ") && ended(", ")")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue