@@ -98,8 +98,8 @@ public Integer getMaxRequestCpus(PipelineJob job)
9898
9999 if (isSequenceNormalizationTask (job ))
100100 {
101- job .getLogger ().debug ("setting max CPUs to 8 " );
102- return 8 ;
101+ job .getLogger ().debug ("setting max CPUs to 4 " );
102+ return 4 ;
103103 }
104104
105105 if (isLuceneIndexJob (job ))
@@ -125,14 +125,14 @@ public Integer getMaxRequestCpus(PipelineJob job)
125125 }
126126 else if (totalFileSize < 20e9 )
127127 {
128- job .getLogger ().debug ("file size less than 20gb, lowering CPUs to 16 " );
128+ job .getLogger ().debug ("file size less than 20gb, lowering CPUs to 12 " );
129129
130- return 16 ;
130+ return 12 ;
131131 }
132132
133- job .getLogger ().debug ("file size greater than 20gb, using 24 CPUs" );
133+ job .getLogger ().debug ("file size greater than 20gb, using 12 CPUs" );
134134
135- return 24 ;
135+ return 12 ;
136136 }
137137
138138 return null ;
@@ -155,8 +155,8 @@ public Integer getMaxRequestMemory(PipelineJob job)
155155
156156 if (isSequenceNormalizationTask (job ))
157157 {
158- job .getLogger ().debug ("setting memory to 48 " );
159- return 48 ;
158+ job .getLogger ().debug ("setting memory to 18 " );
159+ return 18 ;
160160 }
161161
162162 if (isGeneticsTask (job ))
@@ -167,8 +167,8 @@ public Integer getMaxRequestMemory(PipelineJob job)
167167
168168 if (isCacheAlignerIndexesTask (job ))
169169 {
170- job .getLogger ().debug ("setting memory to 48 " );
171- return 48 ;
170+ job .getLogger ().debug ("setting memory to 12 " );
171+ return 12 ;
172172 }
173173
174174 if (isLuceneIndexJob (job ))
@@ -314,7 +314,7 @@ public void addExtraSubmitScriptLines(PipelineJob job, RemoteExecutionEngine eng
314314 }
315315
316316 @ Override
317- public Map <String , Object > getEnvironmentVars (PipelineJob job , RemoteExecutionEngine engine )
317+ public @ NotNull Map <String , Object > getEnvironmentVars (PipelineJob job , RemoteExecutionEngine engine )
318318 {
319319 Map <String , Object > ret = new HashMap <>();
320320
0 commit comments