Skip to content

Commit c876525

Browse files
committed
Bugfix to ConvertToCramHandler
1 parent 655c47a commit c876525

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/pipeline/ConvertToCramHandler.java

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -134,8 +134,6 @@ public void processFilesRemote(List<SequenceOutputFile> inputFiles, JobContext c
134134
new SamtoolsCramConverter(ctx.getLogger()).convert(so.getFile(), outputFile, genome.getWorkingFastaFileGzipped(), true, threads, doCramArchivalMode);
135135
}
136136

137-
checkCramAndIndex(so);
138-
139137
if (replaceOriginal)
140138
{
141139
ctx.getLogger().info("Deleting original BAM/CRAM: {}", so.getFile().getPath());
@@ -180,21 +178,6 @@ else if (SequenceUtil.FILETYPE.cram.getFileType().isType(so.getFile()))
180178
}
181179
}
182180

183-
private void checkCramAndIndex(SequenceOutputFile so) throws PipelineJobException
184-
{
185-
File cram = new File(so.getFile().getParentFile(), FileUtil.getBaseName(so.getFile()) + ".cram");
186-
if (!cram.exists())
187-
{
188-
throw new PipelineJobException("Unable to find file: " + cram.getPath());
189-
}
190-
191-
File cramIdx = new File(cram.getPath() + ".crai");
192-
if (!cramIdx.exists())
193-
{
194-
throw new PipelineJobException("Unable to find file: " + cramIdx.getPath());
195-
}
196-
}
197-
198181
@Override
199182
public void complete(JobContext ctx, List<SequenceOutputFile> inputs, List<SequenceOutputFile> outputsCreated) throws PipelineJobException
200183
{
@@ -210,8 +193,6 @@ public void complete(JobContext ctx, List<SequenceOutputFile> inputs, List<Seque
210193
for (SequenceOutputFile so : inputs)
211194
{
212195
File cram = new File(so.getFile().getParentFile(), FileUtil.getBaseName(so.getFile()) + ".cram");
213-
checkCramAndIndex(so);
214-
215196
if (replaceOriginal)
216197
{
217198
ctx.getJob().getLogger().info("Updating ExpData record with new filepath: " + cram.getPath());

0 commit comments

Comments
 (0)