Skip to content

Commit a79c0ec

Browse files
committed
Improve slurm sacct parsing
1 parent caaeada commit a79c0ec

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

SequenceAnalysis/pipeline_code/extra_tools_install.sh

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -191,6 +191,7 @@ then
191191
cd ../
192192
cp -R paragraph $LKTOOLS_DIR
193193
ln -s ${LKTOOLS_DIR}/paragraph/bin/paragraph ${LKTOOLS_DIR}/paragraph
194+
ln -s ${LKTOOLS_DIR}/paragraph/bin/idxdepth ${LKTOOLS_DIR}/idxdepth
194195
ln -s ${LKTOOLS_DIR}/paragraph/bin/multigrmpy.py ${LKTOOLS_DIR}/multigrmpy.py
195196
else
196197
echo "Already installed"

cluster/src/org/labkey/cluster/pipeline/SlurmExecutionEngine.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -299,13 +299,14 @@ else if (headerFound)
299299
}
300300

301301
// NOTE: if the line has blank ending columns, trimmed lines might lack that value
302-
if (maxRssIdx > -1 && maxRssIdx < tokens.length)
302+
if ((job.getClusterId() + ".0").equals(id) && maxRssIdx > -1 && maxRssIdx < tokens.length)
303303
{
304304
try
305305
{
306-
if (NumberUtils.isCreatable(tokens[maxRssIdx]))
306+
String maxRSS = StringUtils.trimToNull(tokens[maxRssIdx]);
307+
if (maxRSS != null)
307308
{
308-
long bytes = FileSizeFormatter.convertStringRepresentationToBytes(tokens[maxRssIdx]);
309+
long bytes = FileSizeFormatter.convertStringRepresentationToBytes(maxRSS);
309310
long requestInBytes = FileSizeFormatter.convertStringRepresentationToBytes(getConfig().getRequestMemory() + "G"); //request is always GB
310311
if (bytes > requestInBytes)
311312
{

0 commit comments

Comments
 (0)