Interface AnalysisExecutionScheduledTask
-
- All Known Implementing Classes:
AnalysisExecutionScheduledTaskImpl
public interface AnalysisExecutionScheduledTaskA service for executingAnalysisSubmissiontasks.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>cleanupAnalysisSubmissions()Cycle through any completed or erroredAnalysisSubmissions and delete intermediate files in the execution manager.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>executeAnalyses()Cycle through any outstandingAnalysisSubmissions and execute them.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>monitorRunningAnalyses()Cycle through anyAnalysisSubmissions currently running and mark as complete any completed analyses.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>postProcessResults()Cycle through any transferredAnalysisSubmissions and perform post processing as necessaryjava.util.Set<java.util.concurrent.Future<AnalysisSubmission>>prepareAnalyses()Cycle through newAnalysisSubmissions and prepare them for execution.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>transferAnalysesResults()Cycle through any completedAnalysisSubmissions and transfer the results to IRIDA.
-
-
-
Method Detail
-
prepareAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> prepareAnalyses()
Cycle through newAnalysisSubmissions and prepare them for execution.- Returns:
- A
SetofFutureAnalysisSubmissions reflecting the changes in this submission along each of the stages.
-
executeAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> executeAnalyses()
Cycle through any outstandingAnalysisSubmissions and execute them.- Returns:
- A
SetofFutureAnalysisSubmissions reflecting the changes in this submission along each of the stages.
-
monitorRunningAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> monitorRunningAnalyses()
Cycle through anyAnalysisSubmissions currently running and mark as complete any completed analyses.- Returns:
- A
SetofFutureAnalysisSubmissions reflecting the changes in this submission along each of the stages.
-
transferAnalysesResults
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> transferAnalysesResults()
Cycle through any completedAnalysisSubmissions and transfer the results to IRIDA.- Returns:
- A
SetofFutureAnalysisSubmissions reflecting the changes in this submission along each of the stages.
-
postProcessResults
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> postProcessResults()
Cycle through any transferredAnalysisSubmissions and perform post processing as necessary- Returns:
- a Set of Future
AnalysisSubmissions
-
cleanupAnalysisSubmissions
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> cleanupAnalysisSubmissions()
Cycle through any completed or erroredAnalysisSubmissions and delete intermediate files in the execution manager.- Returns:
- A
SetofFutureAnalysisSubmissions for all the analyses that were cleaned.
-
-