 |
A collection of tasks that run in the same environment.
Context objects are typically created by calling Manager::get_context().
Public Member Functions | |
| def | add_task |
| Add a task to this context. | |
| def | get_results_unordered |
| Run all of the tasks on available slaves, and return results. | |
| def IMP.parallel.Context.add_task | ( | self, | |
| task | |||
| ) |
Add a task to this context.
Tasks are any Python callable object that can be pickled (e.g. a function or a class that implements the call method). When the task is run on the slave its arguments are the return value from this context's startup function.
| def IMP.parallel.Context.get_results_unordered | ( | self | ) |
Run all of the tasks on available slaves, and return results.
If there are more tasks than slaves, subsequent tasks are started only once a running task completes: each slave only runs a single task at a time. As each task completes, the return value(s) from the task callable are returned from this method, as a Python generator. Note that the results are returned in the order that tasks complete, which may not be the same as the order they were submitted in.
| NoMoreSlavesError | there are no slaves available to run the tasks (or they all failed during execution). |
| RemoteError | a slave encountered an unhandled exception. |
| NetworkError | the master lost (or was unable to establish) communication with any slave. |