xontrib.distributed#
Hooks for the distributed parallel computing library.
- class xontrib.distributed.DSubmitter(executor, **kwargs)[source]#
Context manager for submitting distributed jobs.
- Parameters
- executordistributed.Executor
The executor to submit to.
- kwargsoptional
All other kwargs are passed up to superclasses init.
- xontrib.distributed.dsubmit(*a, args=(), kwargs=None, rtn='', **kw)[source]#
Returns a distributed submission context manager, DSubmitter(), with a new executor instance.
- Parameters
- argsSequence of str, optional
A tuple of argument names for DSubmitter.
- kwargsMapping of str to values or list of item tuples, optional
Keyword argument names and values for DSubmitter.
- rtnstr, optional
Name of object to return for DSubmitter.
- a, kwSequence and Mapping
All other arguments and keyword arguments are used to construct the executor instance.
- Returns
- dsubDSubmitter
An instance of the DSubmitter context manager.