docs/examples/kernel/asyncmultiengine1.py

#!/usr/bin/env python
# encoding: utf-8

# A super simple example showing how to use all of this in a fully
# asynchronous manner.  The TaskClient also works in this mode.

from twisted.internet import reactor, defer
from IPython.kernel import asyncclient

def printer(r):
    print r
    return r

def submit(client):
    d = client.push(dict(a=5, b='asdf', c=[1,2,3]),targets=0,block=True)
    d.addCallback(lambda _: client.pull(('a','b','c'),targets=0,block=True))
    d.addBoth(printer)
    d.addCallback(lambda _: reactor.stop())

d = asyncclient.get_multiengine_client()
d.addCallback(submit)

reactor.run()