toil.test.mesos.stress

Module Contents

Classes

LongTestJob	Class represents a unit of work in toil.
LongTestFollowOn	Class represents a unit of work in toil.
HelloWorldJob	Class represents a unit of work in toil.
HelloWorldFollowOn	Class represents a unit of work in toil.

Functions

touchFile(fileStore)
main(numJobs)

toil.test.mesos.stress.touchFile(fileStore)

class toil.test.mesos.stress.LongTestJob(numJobs)

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)

Override this function to perform work and dynamically create successor jobs.

Parameters:

fileStore – Used to create local and globally sharable temporary files and to send log messages to the leader process.

Returns:

The return value of the function can be passed to other jobs by means of toil.job.Job.rv().

class toil.test.mesos.stress.LongTestFollowOn

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)

Override this function to perform work and dynamically create successor jobs.

Parameters:

fileStore – Used to create local and globally sharable temporary files and to send log messages to the leader process.

Returns:

The return value of the function can be passed to other jobs by means of toil.job.Job.rv().

class toil.test.mesos.stress.HelloWorldJob(i)

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)

Override this function to perform work and dynamically create successor jobs.

Parameters:

fileStore – Used to create local and globally sharable temporary files and to send log messages to the leader process.

Returns:

The return value of the function can be passed to other jobs by means of toil.job.Job.rv().

class toil.test.mesos.stress.HelloWorldFollowOn(i)

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)

Override this function to perform work and dynamically create successor jobs.

Parameters:

fileStore – Used to create local and globally sharable temporary files and to send log messages to the leader process.

Returns:

The return value of the function can be passed to other jobs by means of toil.job.Job.rv().

toil.test.mesos.stress.main(numJobs)