Class JobarrayRunner

object --+    
         |    
 JobRunner --+
             |
            JobarrayRunner

JobRunner subclass for running subjobs using SGE job arrays. This is normally requested with the -ARRAY command-line option.

Instance Methods

run(self)

launchJobarray(self, tasks)

getPendingTasks(self)

writeTaskmapFile(self, tasks)
Create a file "<jobname>.taskmap" listing the tasks (subjob indices) to be run, one per line.

monitorJobarray(self, job, delay=10)
Wait until the job is done, printing timestamped progress messages along the way.

incorporateJobarray(self)

cleanUp(self)

Inherited from JobRunner: __init__

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

Inherited from object: __class__

Method Details

Wait until the job is done, printing timestamped progress messages along the way. The job record is checked every 'delay' seconds for updates.

Property Details