##// END OF EJS Templates
Option to spew subprocess streams during tests...
Option to spew subprocess streams during tests This supersedes PR #4268. Run the tests with '--subproc-streams show' to show output from subprocesses (kernels, IPython.parallel components) in the terminal, or with '--subproc-streams discard' to send it to /dev/null. By default (or with '--subproc-streams capture') the output is piped, captured and displayed only when tests fail. But in some situations, a test fails because of an error which actually occurred earlier, so you have to see all the output.

File last commit:

r9190:20a102a5
r13824:d77e2f51
Show More
task1.ipynb
139 lines | 2.5 KiB | text/plain | TextLexer

Simple task farming example

In [1]:
from IPython.parallel import Client

A Client.load_balanced_view is used to get the object used for working with load balanced tasks.

In [2]:
rc = Client()
v = rc.load_balanced_view()

Set the variable d on all engines:

In [3]:
rc[:]['d'] = 30

Define a function that will be our task:

In [4]:
def task(a):
    return a, 10*d, a*10*d

Run the task once:

In [5]:
ar = v.apply(task, 5)

Print the results:

In [6]:
print "a, b, c: ", ar.get()
a, b, c:  [5, 300, 1500]
In [ ]: