Skip to content

Commit 5f6e5e0

Browse files
committed
Improve resource check
1 parent 3d18f3a commit 5f6e5e0

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

primeseq/src/org/labkey/primeseq/pipeline/SequenceJobResourceAllocator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,9 @@ private boolean isSequenceAlignmentTask(PipelineJob job)
6969
return (job.getActiveTaskId() != null && job.getActiveTaskId().getNamespaceClass().getName().endsWith("SequenceAlignmentTask"));
7070
}
7171

72-
private boolean isCacheAlignerIndexesTask(PipelineJob job)
72+
private boolean isCacheOrPrepareAlignerIndexesTask(PipelineJob job)
7373
{
74-
return (job.getActiveTaskId() != null && job.getActiveTaskId().getNamespaceClass().getName().endsWith("CacheAlignerIndexesTask"));
74+
return (job.getActiveTaskId() != null && (job.getActiveTaskId().getNamespaceClass().getName().endsWith("CacheAlignerIndexesTask") || job.getActiveTaskId().getNamespaceClass().getName().endsWith("PrepareAlignerIndexesTask")));
7575
}
7676

7777
private boolean isSequenceSequenceOutputHandlerTask(PipelineJob job)
@@ -188,7 +188,7 @@ public Integer getMaxRequestMemory(PipelineJob job)
188188
return 96;
189189
}
190190

191-
if (isCacheAlignerIndexesTask(job))
191+
if (isCacheOrPrepareAlignerIndexesTask(job))
192192
{
193193
int mem = getAlignerIndexMem(job);
194194
job.getLogger().debug("setting memory to: " + mem);

0 commit comments

Comments
 (0)