Skip to content

Commit e5445a4

Browse files
committed
Increase RAM for kinship tasks
1 parent b72102a commit e5445a4

1 file changed

Lines changed: 12 additions & 0 deletions

File tree

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,11 @@ private boolean isSequenceNormalizationTask(PipelineJob job)
5353
return (job.getActiveTaskId() != null && job.getActiveTaskId().getNamespaceClass().getName().endsWith("SequenceNormalizationTask"));
5454
}
5555

56+
private boolean isGeneticsTask(PipelineJob job)
57+
{
58+
return (job.getActiveTaskId() != null && job.getActiveTaskId().getNamespaceClass().getName().endsWith("GeneticCalculationsRTask"));
59+
}
60+
5661
private boolean isLuceneIndexJob(PipelineJob job)
5762
{
5863
return (job.getActiveTaskId() != null && job.getActiveTaskId().getNamespaceClass().getName().endsWith("JBrowseLuceneTask"));
@@ -95,6 +100,7 @@ public Integer getMaxRequestCpus(PipelineJob job)
95100
job.getLogger().debug("setting max CPUs to 8");
96101
return 8;
97102
}
103+
98104
if (isLuceneIndexJob(job))
99105
{
100106
job.getLogger().debug("setting max CPUs to 24");
@@ -152,6 +158,12 @@ public Integer getMaxRequestMemory(PipelineJob job)
152158
return 48;
153159
}
154160

161+
if (isGeneticsTask(job))
162+
{
163+
job.getLogger().debug("setting memory to 72");
164+
return 72;
165+
}
166+
155167
if (isCacheAlignerIndexesTask(job))
156168
{
157169
job.getLogger().debug("setting memory to 48");

0 commit comments

Comments
 (0)