compbio.engine.cluster.drmaa
Class ClusterSession

java.lang.Object
  extended by compbio.engine.cluster.drmaa.ClusterSession

public final class ClusterSession
extends java.lang.Object


Field Summary
static java.lang.String JOBID
           
 
Method Summary
 void close()
           
static ClusterJobId getClusterJobId(java.lang.String taskId)
           
 int getJobStatus(ClusterJobId jobId)
          Apparently completed jobs cannot be found! If this happened most likely that the job is not running any more and Most likely it has been cancelled, finished or failed.
static java.lang.String getJobStatus(int status)
          Deprecated. 
 ConfiguredExecutable<?> getResults(java.lang.String taskId)
           
 org.ggf.drmaa.Session getSession()
           
static StatisticManager getStatistics(org.ggf.drmaa.JobInfo status)
           
 void removeJob(java.lang.String taskId)
           
 org.ggf.drmaa.JobInfo waitForJob(java.lang.String taskId)
           
 org.ggf.drmaa.JobInfo waitForJob(java.lang.String jobId, long waitingTime)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

JOBID

public static final java.lang.String JOBID
See Also:
Constant Field Values
Method Detail

getSession

public org.ggf.drmaa.Session getSession()

close

public void close()

removeJob

public void removeJob(java.lang.String taskId)

waitForJob

public org.ggf.drmaa.JobInfo waitForJob(java.lang.String taskId)
                                 throws org.ggf.drmaa.DrmaaException,
                                        java.io.IOException
Throws:
org.ggf.drmaa.DrmaaException
java.io.IOException

getClusterJobId

public static ClusterJobId getClusterJobId(java.lang.String taskId)
                                    throws java.io.IOException
Throws:
java.io.IOException

waitForJob

public org.ggf.drmaa.JobInfo waitForJob(java.lang.String jobId,
                                        long waitingTime)
                                 throws org.ggf.drmaa.DrmaaException,
                                        java.io.IOException
Throws:
org.ggf.drmaa.DrmaaException
java.io.IOException

getResults

public ConfiguredExecutable<?> getResults(java.lang.String taskId)
                                   throws org.ggf.drmaa.DrmaaException,
                                          ResultNotAvailableException
Throws:
org.ggf.drmaa.DrmaaException
ResultNotAvailableException

getStatistics

public static StatisticManager getStatistics(org.ggf.drmaa.JobInfo status)
                                      throws org.ggf.drmaa.DrmaaException
Throws:
org.ggf.drmaa.DrmaaException

getJobStatus

public int getJobStatus(ClusterJobId jobId)
                 throws org.ggf.drmaa.DrmaaException,
                        org.ggf.drmaa.InvalidJobException
Apparently completed jobs cannot be found! If this happened most likely that the job is not running any more and Most likely it has been cancelled, finished or failed.

Throws:
org.ggf.drmaa.InvalidJobException - if the job is no longer in the queue or running. basically it will throw this exception for all finished or cancelled jobs
org.ggf.drmaa.DrmaaException

getJobStatus

@Deprecated
public static java.lang.String getJobStatus(int status)
                                     throws org.ggf.drmaa.DrmaaException
Deprecated. 

Method for getting jobs status by quering the cluster, It returns status in therms of a Sessions, not a JobStatus Should only be used for testing!

Parameters:
status -
Returns:
Throws:
org.ggf.drmaa.DrmaaException