toil.test.mesos.stress

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)

Module Contents

toil.test.mesos.stress.touchFile(fileStore)[source]
class toil.test.mesos.stress.LongTestJob(numJobs)[source]

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)[source]

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[source]

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)[source]

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)[source]

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)[source]

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)[source]

Bases: toil.job.Job

Class represents a unit of work in toil.

run(fileStore)[source]

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)[source]