pymor.parallel.ipython

Module Contents

Classes

new_ipcluster_pool	Create a new IPython parallel cluster and connect to it.
IPythonPool	WorkerPool based on the IPython parallel computing features.
RemoteId	int([x]) -> integer

Functions

_worker_call_function
_setup_worker
_push_object
_remove_object

class pymor.parallel.ipython.new_ipcluster_pool(profile=None, cluster_id=None, num_engines=None, ipython_dir=None, min_wait=1, timeout=60)

Bases: pymor.core.base.BasicObject

Create a new IPython parallel cluster and connect to it.

This context manager can be used to create an IPythonPool WorkerPool. When entering the context a new IPython cluster is created using the ipcluster script and an IPythonPool is instantiated for the newly created cluster. When leaving the context the cluster is shut down.

Parameters

profile

Passed as --profile parameter to the ipcluster script.

cluster_id

Passed as --cluster-id parameter to the ipcluster script.

nun_engines

Passed as --n parameter to the ipcluster script.

ipython_dir

Passed as --ipython-dir parameter to the ipcluster script.

min_wait

Wait at least this many seconds before trying to connect to the new cluster.

timeout

Wait at most this many seconds for all Ipython cluster engines to become available.

__enter__(self)

__exit__(self, exc_type, exc_val, exc_tb)

class pymor.parallel.ipython.IPythonPool(num_engines=None, **kwargs)

Bases: pymor.parallel.basic.WorkerPoolBase

WorkerPool based on the IPython parallel computing features.

Parameters

num_engines

Number of IPython engines to use. If None, all available engines are used.

kwargs

Keyword arguments used to instantiate the IPython cluster client.

_updated_defaults = 0

__len__(self)

The number of workers in the pool.

_push_object(self, obj)

_apply(self, function, *args, **kwargs)

_apply_only(self, function, worker, *args, **kwargs)

_map(self, function, chunks, **kwargs)

_remove_object(self, remote_id)

_update_defaults(self)

class pymor.parallel.ipython.RemoteId

Bases: int

int([x]) -> integer int(x, base=10) -> integer

Convert a number or string to an integer, or return 0 if no arguments are given. If x is a number, return x.__int__(). For floating point numbers, this truncates towards zero.

If x is not a number or if base is given, then x must be a string, bytes, or bytearray instance representing an integer literal in the given base. The literal can be preceded by ‘+’ or ‘-’ and be surrounded by whitespace. The base defaults to 10. Valid bases are 0 and 2-36. Base 0 means to interpret the base from the string as an integer literal. >>> int(‘0b100’, base=0) 4

pymor.parallel.ipython._worker_call_function(function, loop, args, kwargs)

pymor.parallel.ipython._setup_worker(worker_id)

pymor.parallel.ipython._push_object(remote_id, obj)

pymor.parallel.ipython._remove_object(remote_id)