Skip to content

Commit d9113b2

Browse files
committed
Add complete() method for VariantProcessingStep and create step to auto-create/update release tracks for mGAP
1 parent 8efe692 commit d9113b2

File tree

2 files changed

+18
-1
lines changed

2 files changed

+18
-1
lines changed

SequenceAnalysis/api-src/org/labkey/api/sequenceanalysis/pipeline/VariantProcessingStep.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,11 @@ default void init(PipelineJob job, SequenceAnalysisJobSupport support, List<Sequ
3838

3939
}
4040

41+
default void complete(PipelineJob job, List<SequenceOutputFile> inputs, List<SequenceOutputFile> outputsCreated, SequenceAnalysisJobSupport support) throws PipelineJobException
42+
{
43+
44+
}
45+
4146
enum ScatterGatherMethod
4247
{
4348
none(),

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

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -696,13 +696,25 @@ public void processFilesOnWebserver(PipelineJob job, SequenceAnalysisJobSupport
696696
{
697697

698698
}
699+
700+
@Override
701+
public void complete(PipelineJob job, List<SequenceOutputFile> inputs, List<SequenceOutputFile> outputsCreated, SequenceAnalysisJobSupport support) throws PipelineJobException
702+
{
703+
SequenceTaskHelper taskHelper = new SequenceTaskHelper(getPipelineJob(job), getPipelineJob(job).getDataDirectory());
704+
List<PipelineStepCtx<VariantProcessingStep>> providers = SequencePipelineService.get().getSteps(job, VariantProcessingStep.class);
705+
for (PipelineStepCtx<VariantProcessingStep> stepCtx : providers)
706+
{
707+
VariantProcessingStep step = stepCtx.getProvider().create(taskHelper);
708+
step.complete(job, inputs, outputsCreated, support);
709+
}
710+
}
699711
}
700712

701713
@Override
702714
public Collection<String> getAllowableActionNames()
703715
{
704716
Set<String> allowableNames = new HashSet<>();
705-
for (PipelineStepProvider provider: SequencePipelineService.get().getProviders(VariantProcessingStep.class))
717+
for (PipelineStepProvider<?> provider: SequencePipelineService.get().getProviders(VariantProcessingStep.class))
706718
{
707719
allowableNames.add(provider.getLabel());
708720
}

0 commit comments

Comments
 (0)