[IPython-dev] load_balanced_view

Satrajit Ghosh satra at mit.edu
Mon Apr 23 16:07:05 EDT 2012


thanks min,

def task_one(b):
>     "store b in global a, for some reason"
>     global a
>     a = b
>
> def task_two(c):
>     "product of a and c, must be run following task_one"
>     return c*a
>
> rc = parallel.Client()
>
> view = rc.load_balanced_view()
>
> # submit task_one anywhere
> ar_one = view.apply_async(task_one, 5)
>
> # submit task_two to the same engine as task_one (even though we don't
> know where that is, yet)
> with view.temp_flags(follow=ar_one):
>     ar_two = view.apply_async(task_two, 10)
>

this is exactly what i needed. thanks for this.


>  We call these Graph Dependencies, and you can read a bit more about them in
> the docs<http://ipython.org/ipython-doc/dev/parallel/parallel_task.html#graph-dependencies>
> .
>

just read them and they are plenty clear.

cheers,

satra
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://mail.python.org/pipermail/ipython-dev/attachments/20120423/3f0427d4/attachment.html>


More information about the IPython-dev mailing list