upstream/ipython Files · docs/examples/kernel/asyncmultiengine1.py

Fix some tests using magics....

Fix some tests using magics. For some odd reason, %hist isn't getting loaded into the ipython instance running the tests. But by loading it manually, now the tests do run and pass. Similarly, load %clear manually so it can be tested.

Brian E Granger - - Load All Authors

File last commit:

r1338:72652d65


                r2092:c152d328

Download file

             asyncmultiengine1.py
        
                    22 lines
            
             | 614 B
            
                | text/x-python
            
             |
                PythonLexer
            
             / docs / examples / kernel / asyncmultiengine1.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      #!/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()

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				#!/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()