Skip to content

Commit 11fdc1f

Browse files
committed
Bugfix to handling of performAdditionalMergeTasks
1 parent d2b2f33 commit 11fdc1f

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -877,10 +877,9 @@ public void performAdditionalMergeTasks(JobContext ctx, PipelineJob job, TaskFil
877877
List<PipelineStepCtx<VariantProcessingStep>> providers = SequencePipelineService.get().getSteps(job, VariantProcessingStep.class);
878878
for (PipelineStepCtx<VariantProcessingStep> stepCtx : providers)
879879
{
880-
if (stepCtx.getProvider() instanceof VariantProcessingStep.SupportsScatterGather)
880+
if (stepCtx.getProvider() instanceof VariantProcessingStep.SupportsScatterGather ssg)
881881
{
882-
VariantProcessingStep step = stepCtx.getProvider().create(ctx);
883-
((VariantProcessingStep.SupportsScatterGather)step).performAdditionalMergeTasks(ctx, job, manager, genome, orderedScatterOutputs);
882+
ssg.performAdditionalMergeTasks(ctx, job, manager, genome, orderedScatterOutputs);
884883
}
885884
}
886885
}

0 commit comments

Comments
 (0)