A python package for DRM job submission and control.
This package is an implementation of the DRMAA 1.0 Python language binding specification (http://www.ogf.org/documents/GFD.143.pdf). See http://drmaa-python.googlecode.com for package info and download.
author: | Enrico Sirola (enrico.sirola@statpro.com) |
---|---|
author: | Dan Blanchard (dblanchard@ets.org) |
Bases: tuple
JobInfo(jobId, hasExited, hasSignal, terminatedSignal, hasCoreDump, wasAborted, exitStatus, resourceUsage)
Alias for field number 6
Alias for field number 4
Alias for field number 1
Alias for field number 2
Alias for field number 0
Alias for field number 7
Alias for field number 3
Alias for field number 5
Bases: object
A job to be submitted to the DRM.
The list of supported DRMAA scalar attribute names.
This is apparently useless now, and should probably substituted by the list of attribute names of the JobTemplate instances.
Deallocate the underlying DRMAA job template.
Bases: object
The DRMAA Session.
This class is the entry point for communicating with the DRM system
Used to hold, release, suspend, resume, or kill the job identified by jobId.
Parameters : |
|
---|
To avoid thread races in multithreaded applications, the DRMAA implementation user should explicitly synchronize this call with any other job submission calls or control calls that may change the number of remote jobs.
This method returns once the action has been acknowledged by the DRM system, but does not necessarily wait until the action has been completed. Some DRMAA implementations may allow this method to be used to control jobs submitted external to the DRMAA session, such as jobs submitted by other DRMAA session in other DRMAA implementations or jobs submitted via native utilities.
Allocates a new job template.
The job template is used to set the environment for jobs to be submitted. Once the job template has been created, it should also be deleted (via deleteJobTemplate()) when no longer needed. Failure to do so may result in a memory leak.
Deallocate a job template.
Parameters : |
|
---|
This routine has no effect on running jobs.
Used to disengage from DRM.
This routine ends the current DRMAA session but doesn’t affect any jobs (e.g., queued and running jobs remain queued and running). exit() should be called only once, by only one of the threads. Additional calls to exit() beyond the first will throw a NoActiveSessionException.
Used to initialize a DRMAA session for use.
Parameters : |
|
---|
This method must be called before any other DRMAA calls. If contactString is None, the default DRM system is used, provided there is only one DRMAA implementation available. If there is more than one DRMAA implementation available, initialize() throws a NoDefaultContactStringSelectedException. initialize() should be called only once, by only one of the threads. The main thread is recommended. A call to initialize() by another thread or additional calls to initialize() by the same thread with throw a SessionAlreadyActiveException.
returns the program status of the job identified by jobId.
The possible values returned from this method are:
JobState.UNDETERMINED: process status cannot be determined,
JobState.QUEUED_ACTIVE: job is queued and active,
JobState.SYSTEM_ON_HOLD: job is queued and in system hold,
JobState.USER_ON_HOLD: job is queued and in user hold,
system hold,
JobState.RUNNING: job is running,
JobState.SYSTEM_SUSPENDED: job is system suspended,
JobState.USER_SUSPENDED: job is user suspended,
JobState.DONE: job finished normally, and
JobState.FAILED: job finished, but failed.
The DRMAA implementation should always get the status of the job from the DRM system unless the status has already been determined to be FAILED or DONE and the status has been successfully cached. Terminated jobs return a FAILED status.
Submit a set of parametric jobs, each with attributes defined in the job template.
Parameters : |
|
---|
The returned job identifiers are Strings identical to those returned from the underlying DRM system. The JobTemplate class defines a JobTemplate.PARAMETRIC_INDEX placeholder for use in specifying paths. This placeholder is used to represent the individual identifiers of the tasks submitted through this method.
Submit a job with attributes defined in the job template.
Parameters : |
|
---|
The returned job identifier is a String identical to that returned from the underlying DRM system.
Waits until all jobs specified by jobList have finished execution.
Parameters : |
|
---|
To avoid thread race conditions in multithreaded applications, the DRMAA implementation user should explicitly synchronize this call with any other job submission calls or control calls that may change the number of remote jobs.
If the call exits before the timeout has elapsed, all the jobs have been waited on or there was an interrupt. If the invocation exits on timeout, an ExitTimeoutException is thrown. The caller should check system time before and after this call in order to be sure of how much time has passed.
Wait for a job with jobId to finish execution or fail.
Parameters : |
|
---|
This routine is modeled on the wait3 POSIX routine. If the call exits before timeout, either the job has been waited on successfully or there was an interrupt. If the invocation exits on timeout, an ExitTimeoutException is thrown. The caller should check system time before and after this call in order to be sure how much time has passed. The routine reaps job data records on a successful call, so any subsequent calls to wait() will fail, throwing an InvalidJobException, meaning that the job’s data record has been already reaped. This exception is the same as if the job were unknown. (The only case where wait() can be successfully called on a single job more than once is when the previous call to wait() timed out before the job finished.)
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException, exceptions.AttributeError
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException, exceptions.AttributeError
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException
Bases: drmaa.errors.DrmaaException, exceptions.AttributeError
Bases: drmaa.errors.DrmaaException, exceptions.AttributeError
Bases: drmaa.errors.DrmaaException, exceptions.AttributeError
Bases: drmaa.errors.DrmaaException, exceptions.MemoryError
Bases: object
Bases: object
Bases: object