Documentation
¶
Index ¶
- func AddArrayJobAsSingleJobs(jt drmaa2interface.JobTemplate, t jobtracker.JobTracker, begin int, end int, ...) (string, error)
- func ArrayJobID2GUIDs(id string) ([]string, error)
- func Guids2ArrayJobID(guids []string) string
- func IsInExpectedState(state drmaa2interface.JobState, states ...drmaa2interface.JobState) bool
- func WaitForState(jt jobtracker.JobTracker, jobid string, timeout time.Duration, ...) error
- func WaitForStateWithInterval(jt jobtracker.JobTracker, interval time.Duration, jobid string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddArrayJobAsSingleJobs ¶
func AddArrayJobAsSingleJobs(jt drmaa2interface.JobTemplate, t jobtracker.JobTracker, begin int, end int, step int) (string, error)
AddArrayJobAsSingleJobs takes an job array definition and submits single jobs through the AddJob() method of the given job tracker. This function is typically needed when a DRM does not support job arrays natively. The returned array job ID is created from all of the returned job IDs and does not work with the DRM directly.
func ArrayJobID2GUIDs ¶
ArrayJobID2GUIDs converts the array job ID returned from the AddArrayJobAsSingleJobs.
func Guids2ArrayJobID ¶
Guids2ArrayJobID creates an array job ID out of the given single job IDs.
func IsInExpectedState ¶
func IsInExpectedState(state drmaa2interface.JobState, states ...drmaa2interface.JobState) bool
IsInExpectedState checks if state is in one of the given states.
func WaitForState ¶
func WaitForState(jt jobtracker.JobTracker, jobid string, timeout time.Duration, states ...drmaa2interface.JobState) error
WaitForState blocks until job is in any of the given states or a timeout happens. It checks the job state every 100 ms.
func WaitForStateWithInterval ¶ added in v0.2.4
func WaitForStateWithInterval(jt jobtracker.JobTracker, interval time.Duration, jobid string, timeout time.Duration, states ...drmaa2interface.JobState) error
WaitForStateWithInterval blocks until the job is any of the given states or a timeout happens. The time interval for job state check calls is given as parameter.
Types ¶
This section is empty.
Source Files