Interface AnalysisExecutionScheduledTask
-
- All Known Implementing Classes:
AnalysisExecutionScheduledTaskImpl
public interface AnalysisExecutionScheduledTask
A service for executingAnalysisSubmission
tasks.
-
-
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 erroredAnalysisSubmission
s and delete intermediate files in the execution manager.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>
executeAnalyses()
Cycle through any outstandingAnalysisSubmission
s and execute them.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>
monitorRunningAnalyses()
Cycle through anyAnalysisSubmission
s currently running and mark as complete any completed analyses.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>
postProcessResults()
Cycle through any transferredAnalysisSubmission
s and perform post processing as necessaryjava.util.Set<java.util.concurrent.Future<AnalysisSubmission>>
prepareAnalyses()
Cycle through newAnalysisSubmission
s and prepare them for execution.java.util.Set<java.util.concurrent.Future<AnalysisSubmission>>
transferAnalysesResults()
Cycle through any completedAnalysisSubmission
s and transfer the results to IRIDA.
-
-
-
Method Detail
-
prepareAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> prepareAnalyses()
Cycle through newAnalysisSubmission
s and prepare them for execution.- Returns:
- A
Set
ofFuture
AnalysisSubmission
s reflecting the changes in this submission along each of the stages.
-
executeAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> executeAnalyses()
Cycle through any outstandingAnalysisSubmission
s and execute them.- Returns:
- A
Set
ofFuture
AnalysisSubmission
s reflecting the changes in this submission along each of the stages.
-
monitorRunningAnalyses
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> monitorRunningAnalyses()
Cycle through anyAnalysisSubmission
s currently running and mark as complete any completed analyses.- Returns:
- A
Set
ofFuture
AnalysisSubmission
s reflecting the changes in this submission along each of the stages.
-
transferAnalysesResults
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> transferAnalysesResults()
Cycle through any completedAnalysisSubmission
s and transfer the results to IRIDA.- Returns:
- A
Set
ofFuture
AnalysisSubmission
s reflecting the changes in this submission along each of the stages.
-
postProcessResults
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> postProcessResults()
Cycle through any transferredAnalysisSubmission
s and perform post processing as necessary- Returns:
- a Set of Future
AnalysisSubmission
s
-
cleanupAnalysisSubmissions
java.util.Set<java.util.concurrent.Future<AnalysisSubmission>> cleanupAnalysisSubmissions()
Cycle through any completed or erroredAnalysisSubmission
s and delete intermediate files in the execution manager.- Returns:
- A
Set
ofFuture
AnalysisSubmission
s for all the analyses that were cleaned.
-
-