Package ca.corefacility.bioinformatics.irida.config.services.scheduled

Class AnalysisScheduledTaskConfig

java.lang.Object

ca.corefacility.bioinformatics.irida.config.services.scheduled.AnalysisScheduledTaskConfig

@Profile({"prod","analysis"})
@Configuration
public class AnalysisScheduledTaskConfig
extends java.lang.Object

Scheduled task configuration for running analysis pipelines

Constructor Summary

Constructors

Constructor	Description
AnalysisScheduledTaskConfig()

Method Summary

Modifier and Type	Method	Description
AnalysisExecutionScheduledTask	analysisExecutionScheduledTask()	Creates a new bean with a AnalysisExecutionScheduledTask for performing the analysis tasks.
CleanupAnalysisSubmissionCondition	cleanupAnalysisSubmissionCondition()	Builds a condition object defining the conditions under which an analysis submission should be cleaned up.
void	cleanupAnalysisSubmissions()	Cycle through any completed or error submissions and clean up results from the execution manager.
void	executeAnalyses()	Cycle through any outstanding submissions and execute them.
void	monitorRunningAnalyses()	Cycle through any submissions running in Galaxy and monitor the status.
void	postProcessResults()	Cycle through any transferred submissions and perform post-processing
void	prepareAnalyses()	Cycle through any submissions and prepare them for execution.
void	transferAnalysesResults()	Cycle through any completed submissions and transfer the results.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AnalysisScheduledTaskConfig

public AnalysisScheduledTaskConfig()

Method Detail

prepareAnalyses

@Scheduled(initialDelay=2000L,
           fixedDelay=15000L)
public void prepareAnalyses()

Cycle through any submissions and prepare them for execution.

executeAnalyses

@Scheduled(initialDelay=3000L,
           fixedDelay=15000L)
public void executeAnalyses()

Cycle through any outstanding submissions and execute them.

monitorRunningAnalyses

@Scheduled(initialDelay=4000L,
           fixedDelay=15000L)
public void monitorRunningAnalyses()

Cycle through any submissions running in Galaxy and monitor the status.

transferAnalysesResults

@Scheduled(initialDelay=5000L,
           fixedDelay=15000L)
public void transferAnalysesResults()

Cycle through any completed submissions and transfer the results.

postProcessResults

@Scheduled(initialDelay=6000L,
           fixedDelay=15000L)
public void postProcessResults()

Cycle through any transferred submissions and perform post-processing

cleanupAnalysisSubmissions

@Scheduled(initialDelay=10000L,
           fixedDelay=3600000L)
public void cleanupAnalysisSubmissions()

Cycle through any completed or error submissions and clean up results from the execution manager.

analysisExecutionScheduledTask

@DependsOn("analysisSubmissionCleanupService")
@Bean
public AnalysisExecutionScheduledTask analysisExecutionScheduledTask()

Creates a new bean with a AnalysisExecutionScheduledTask for performing the analysis tasks.

Returns:

A AnalysisExecutionScheduledTask bean.

cleanupAnalysisSubmissionCondition

@Bean
public CleanupAnalysisSubmissionCondition cleanupAnalysisSubmissionCondition()

Builds a condition object defining the conditions under which an analysis submission should be cleaned up.

Returns:

A CleanupAnalysisSubmissionConditionAge.