Package ca.corefacility.bioinformatics.irida.service.analysis.execution.galaxy

Class AnalysisExecutionServiceGalaxyCleanupAsync

java.lang.Object

ca.corefacility.bioinformatics.irida.service.analysis.execution.galaxy.AnalysisExecutionServiceGalaxyCleanupAsync

@Async("analysisTaskExecutor")
public class AnalysisExecutionServiceGalaxyCleanupAsync
extends java.lang.Object

Service for cleaning up an AnalysisSubmission within a Galaxy execution manager asynchronously.

Constructor Summary

Constructors

Constructor	Description
AnalysisExecutionServiceGalaxyCleanupAsync(AnalysisSubmissionService analysisSubmissionService, GalaxyWorkflowService galaxyWorkflowService, GalaxyHistoriesService galaxyHistoriesService, GalaxyLibrariesService galaxyLibrariesService)	Builds a new AnalysisExecutionServiceGalaxyCleanupAsync with the given information.

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.Future<AnalysisSubmission>	cleanupSubmission(AnalysisSubmission analysisSubmission)	Cleans up any intermediate files from this AnalysisSubmission in the execution manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalysisExecutionServiceGalaxyCleanupAsync

@Autowired
public AnalysisExecutionServiceGalaxyCleanupAsync(AnalysisSubmissionService analysisSubmissionService,
                                                  GalaxyWorkflowService galaxyWorkflowService,
                                                  GalaxyHistoriesService galaxyHistoriesService,
                                                  GalaxyLibrariesService galaxyLibrariesService)

Builds a new AnalysisExecutionServiceGalaxyCleanupAsync with the given information.

Parameters:

analysisSubmissionService - A service for analysis submissions.

galaxyWorkflowService - A service for Galaxy workflows.

galaxyHistoriesService - A service for Galaxy histories.

galaxyLibrariesService - A service for Galaxy libraries.

Method Detail

cleanupSubmission

public java.util.concurrent.Future<AnalysisSubmission> cleanupSubmission(AnalysisSubmission analysisSubmission)
                                                                  throws ExecutionManagerException

Cleans up any intermediate files from this AnalysisSubmission in the execution manager.

Parameters:

analysisSubmission - The AnalysisSubmission to clean.

Returns:

A Future with an AnalysisSubmission object that will be cleaned.

Throws:

ExecutionManagerException - If there was an error while cleaning up files in the execution manager.