|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object compbio.engine.cluster.drmaa.AsyncJobRunner
public class AsyncJobRunner
Single cluster job runner class
Constructor Summary | |
---|---|
AsyncJobRunner()
|
Method Summary | |
---|---|
boolean |
cancelJob(java.lang.String jobId)
Stop running job. |
boolean |
cleanup(java.lang.String jobId)
Remove all files and a job directory for a jobid. |
JobStatus |
getJobStatus(java.lang.String jobId)
This will never return clust.engine.JobStatus.CANCELLED as for sun grid engine cancelled job is the same as failed. |
ConfiguredExecutable<?> |
getResults(java.lang.String jobId)
Retrieve the results of the job. |
java.lang.String |
getWorkDirectory(java.lang.String jobId)
|
java.lang.String |
submitJob(ConfiguredExecutable<?> executable)
Submits job for the execution Immediate execution is not guaranteed, this method puts the job in the queue. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AsyncJobRunner()
Method Detail |
---|
public java.lang.String submitJob(ConfiguredExecutable<?> executable) throws JobSubmissionException
AsyncExecutor
submitJob
in interface AsyncExecutor
JobSubmissionException
- if submission fails. This usually happens due to the problem on a server side.public boolean cancelJob(java.lang.String jobId)
AsyncExecutor
cancelJob
in interface AsyncExecutor
public JobStatus getJobStatus(java.lang.String jobId)
getJobStatus
in interface AsyncExecutor
JobStatus
public boolean cleanup(java.lang.String jobId)
AsyncExecutor
cleanup
in interface AsyncExecutor
public ConfiguredExecutable<?> getResults(java.lang.String jobId) throws ResultNotAvailableException
AsyncExecutor
getResults
in interface AsyncExecutor
jobId
- job identifier obtained at the job submission
ResultNotAvailableException
- if the result is not available for whatever reason.
Could be due to execution failure, or due to the results being removed from the server at
the time of request.public java.lang.String getWorkDirectory(java.lang.String jobId)
getWorkDirectory
in interface AsyncExecutor
jobId
- unique job identifier
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |