toil.test.mesos.stress
¶
Module Contents¶
Classes¶
Class represents a unit of work in toil. |
|
Class represents a unit of work in toil. |
|
Class represents a unit of work in toil. |
|
Class represents a unit of work in toil. |
Functions¶
|
|
|
- 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)¶