Skip to content

Commit 315425f

Browse files
Migrate from ProcessBuilder to LabKeyProcessBuilder
1 parent 3ada127 commit 315425f

2 files changed

Lines changed: 9 additions & 7 deletions

File tree

SequenceAnalysis/api-src/org/labkey/api/sequenceanalysis/run/AbstractCommandWrapper.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,12 +17,13 @@
1717

1818
import org.apache.commons.lang3.StringUtils;
1919
import org.apache.logging.log4j.Level;
20-
import org.apache.logging.log4j.Logger;
2120
import org.apache.logging.log4j.LogManager;
21+
import org.apache.logging.log4j.Logger;
2222
import org.jetbrains.annotations.Nullable;
2323
import org.labkey.api.pipeline.PipelineJobException;
2424
import org.labkey.api.pipeline.PipelineJobService;
2525
import org.labkey.api.sequenceanalysis.pipeline.SequencePipelineService;
26+
import org.labkey.api.util.LabKeyProcessBuilder;
2627
import org.labkey.api.util.StringUtilsLabKey;
2728

2829
import java.io.BufferedReader;
@@ -43,7 +44,7 @@ abstract public class AbstractCommandWrapper implements CommandWrapper
4344
{
4445
private File _outputDir = null;
4546
private File _workingDir = null;
46-
private Logger _log;
47+
private final Logger _log;
4748
private boolean _logPath = false;
4849
private Level _logLevel = Level.DEBUG;
4950
private boolean _warnNonZeroExits = true;
@@ -105,9 +106,9 @@ public void execute(List<String> params, ProcessBuilder.Redirect redirect) throw
105106
execute(params, redirect, null);
106107
}
107108

108-
public ProcessBuilder getProcessBuilder(List<String> params)
109+
public LabKeyProcessBuilder getProcessBuilder(List<String> params)
109110
{
110-
ProcessBuilder pb = new ProcessBuilder(params);
111+
LabKeyProcessBuilder pb = new LabKeyProcessBuilder(params);
111112
setPath(pb);
112113

113114
if (!_environment.isEmpty())
@@ -134,7 +135,7 @@ private void execute(List<String> params, ProcessBuilder.Redirect redirect, @Nul
134135
getLogger().info("\t" + StringUtils.join(params, " "));
135136
_commandsExecuted.add(StringUtils.join(params, " "));
136137

137-
ProcessBuilder pb = getProcessBuilder(params);
138+
LabKeyProcessBuilder pb = getProcessBuilder(params);
138139
pb.redirectErrorStream(false);
139140
if (redirect != null)
140141
{
@@ -197,7 +198,7 @@ public Integer getLastReturnCode()
197198
return _lastReturnCode;
198199
}
199200

200-
private void setPath(ProcessBuilder pb)
201+
private void setPath(LabKeyProcessBuilder pb)
201202
{
202203
// Update PATH environment variable to make sure all files in the tools
203204
// directory and the directory of the executable or on the path.

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/preprocessing/TrimmomaticWrapper.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import org.labkey.api.sequenceanalysis.run.AbstractCommandWrapper;
2222
import org.labkey.api.util.FileUtil;
2323
import org.labkey.api.util.JobRunner;
24+
import org.labkey.api.util.LabKeyProcessBuilder;
2425
import org.labkey.api.util.Pair;
2526
import org.labkey.api.util.StringUtilsLabKey;
2627
import org.labkey.sequenceanalysis.model.AdapterModel;
@@ -272,7 +273,7 @@ else if (FileUtils.sizeOf(files.get(2)) == 0)
272273

273274
public void doTrim(List<String> params) throws PipelineJobException
274275
{
275-
ProcessBuilder pb = getProcessBuilder(params);
276+
LabKeyProcessBuilder pb = getProcessBuilder(params);
276277
getLogger().info(StringUtils.join(params, " "));
277278
pb.redirectErrorStream(false);
278279
Process p = null;

0 commit comments

Comments
 (0)