Skip to content

Commit 72abde8

Browse files
committed
Add more pipeline logging
1 parent 0e634a8 commit 72abde8

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

mGAP/src/org/labkey/mgap/pipeline/GenerateMgapTracksStep.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -428,6 +428,7 @@ public void performAdditionalMergeTasks(SequenceOutputHandler.JobContext ctx, Pi
428428
Map<String, List<String>> trackToSamples = parseSampleMap(getSampleNameFile(getPipelineCtx().getSourceDirectory(true)));
429429
for (String trackName : trackToSamples.keySet())
430430
{
431+
job.getLogger().debug("Merging track: " + trackName);
431432
List<File> toConcat = orderedJobDirs.stream().map(dirName -> {
432433
File f = getOutputVcf(trackName, new File(ctx.getWorkingDirectory(), dirName));
433434
if (!f.exists())
@@ -440,6 +441,11 @@ public void performAdditionalMergeTasks(SequenceOutputHandler.JobContext ctx, Pi
440441

441442
return f;
442443
}).toList();
444+
job.getLogger().debug("Total VCFs to merge: " + toConcat.size());
445+
if (toConcat.isEmpty())
446+
{
447+
throw new PipelineJobException("No VCFs found for track: " + trackName);
448+
}
443449

444450
String basename = SequenceAnalysisService.get().getUnzippedBaseName(toConcat.get(0).getName());
445451
File combined = new File(ctx.getSourceDirectory(), basename + ".vcf.gz");

0 commit comments

Comments
 (0)