4.11.1. batch Package¶

4.11.1.1. batch Package¶

4.11.1.2. student Module¶

class rootpy.batch.student.Student(name, files, output_queue, logging_queue, gridmode=False, metadata=None, profile=False, nice=0, **kwargs)[source]¶

Bases: multiprocessing.process.Process

static merge(inputs, output, metadata)[source]¶

Default merging mechanism. Override this method to define merging behaviour suitable to your needs.

run()[source]¶

work()[source]¶

You must implement this method in your Student-derived class

4.11.1.3. supervisor Module¶

class rootpy.batch.supervisor.QueueFeeder(connection, objects, queue, numclients, sentinel=None)[source]¶

Bases: multiprocessing.process.Process

run()[source]¶

class rootpy.batch.supervisor.Supervisor(student, files, outputname, outputpath='.', metadata=None, nstudents=2, connection=None, gridmode=False, queuemode=True, nice=0, name=None, profile=False, args=None, **kwargs)[source]¶

Bases: multiprocessing.process.Process

hire_students()[source]¶

publish()[source]¶

retire()[source]¶

run()[source]¶

supervise()[source]¶