Skip to content

Commit 69479e9

Browse files
committed
Bugfix SRA download
1 parent 098bb39 commit 69479e9

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1894,10 +1894,10 @@ private void restoreArchivedReadDataIfNeeded(Readset rs) throws PipelineJobExcep
18941894
RestoreSraDataHandler.FastqDumpWrapper sra = new RestoreSraDataHandler.FastqDumpWrapper(getJob().getLogger());
18951895
if (doneFile.exists())
18961896
{
1897-
rdi.setFile(new File(outDir, rd.getSra_accession() + "_1.fastq"), 1);
1897+
rdi.setFile(new File(outDir, rd.getSra_accession() + "_1.fastq.gz"), 1);
18981898
if (rd.getFileId2() != null)
18991899
{
1900-
rdi.setFile(new File(outDir, rd.getSra_accession() + "_2.fastq"), 2);
1900+
rdi.setFile(new File(outDir, rd.getSra_accession() + "_2.fastq.gz"), 2);
19011901
}
19021902
}
19031903
else

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/RestoreSraDataHandler.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -512,8 +512,11 @@ public Pair<File, File> downloadSra(String dataset, File outDir) throws Pipeline
512512
{
513513
getLogger().info("Deleting extra files: ");
514514
files.forEach(f -> {
515-
getLogger().info(f.getName());
516-
f.delete();
515+
if (f.exists())
516+
{
517+
getLogger().info(f.getName());
518+
f.delete();
519+
}
517520
});
518521
}
519522

0 commit comments

Comments
 (0)