Skip to content

Commit 8bfdceb

Browse files
committed
Fix paraGRAPH / idxdepth args
1 parent f99aba9 commit 8bfdceb

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/alignment/ParagraphStep.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,11 +76,12 @@ public void processFilesRemote(List<SequenceOutputFile> inputFiles, JobContext c
7676
throw new PipelineJobException("Unable to find file: " + inputVCF.getPath());
7777
}
7878

79+
Integer threads = SequencePipelineService.get().getMaxThreads(ctx.getLogger());
7980
for (SequenceOutputFile so : inputFiles)
8081
{
8182
List<String> depthArgs = new ArrayList<>();
8283
depthArgs.add("idxdepth");
83-
depthArgs.add("-d");
84+
depthArgs.add("-b");
8485
depthArgs.add(so.getFile().getPath());
8586

8687
File coverageFile = new File(ctx.getWorkingDirectory(), "coverage.txt");
@@ -90,6 +91,12 @@ public void processFilesRemote(List<SequenceOutputFile> inputFiles, JobContext c
9091
depthArgs.add("-r");
9192
depthArgs.add(ctx.getSequenceSupport().getCachedGenome(so.getLibrary_id()).getWorkingFastaFile().getPath());
9293

94+
if (threads != null)
95+
{
96+
depthArgs.add("--threads");
97+
depthArgs.add(threads.toString());
98+
}
99+
93100
new SimpleScriptWrapper(ctx.getLogger()).execute(depthArgs);
94101

95102
if (!coverageFile.exists())
@@ -137,7 +144,6 @@ else if (!svVcf.exists())
137144
paragraphArgs.add("--scratch-dir");
138145
paragraphArgs.add(SequencePipelineService.get().getJavaTempDir());
139146

140-
Integer threads = SequencePipelineService.get().getMaxThreads(ctx.getLogger());
141147
if (threads != null)
142148
{
143149
paragraphArgs.add("--threads");

0 commit comments

Comments
 (0)