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

Updated the docs for using MPI with IPython.

Brian E Granger - - Load All Authors

File last commit:

r1396:ee81bbeb


                r1778:8a18869b

Download file

             helloworld.py
        
                    14 lines
            
             | 532 B
            
                | text/x-python
            
             |
                PythonLexer
            
             / docs / examples / kernel / helloworld.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      """

      A Distributed Hello world

      Ken Kinder <ken@kenkinder.com>

      """

      from IPython.kernel import client

      tc = client.TaskClient()

      mec = client.MultiEngineClient()

      mec.execute('import time')

      hello_taskid = tc.run(client.StringTask('time.sleep(3) ; word = "Hello,"', pull=('word')))

      world_taskid = tc.run(client.StringTask('time.sleep(3) ; word = "World!"', pull=('word')))

      print "Submitted tasks:", hello_taskid, world_taskid

      print tc.get_task_result(hello_taskid,block=True).ns.word, tc.get_task_result(world_taskid,block=True).ns.word

	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

				"""
				A Distributed Hello world
				Ken Kinder <ken@kenkinder.com>
				"""
				from IPython.kernel import client

				tc = client.TaskClient()
				mec = client.MultiEngineClient()

				mec.execute('import time')
				hello_taskid = tc.run(client.StringTask('time.sleep(3) ; word = "Hello,"', pull=('word')))
				world_taskid = tc.run(client.StringTask('time.sleep(3) ; word = "World!"', pull=('word')))
				print "Submitted tasks:", hello_taskid, world_taskid
				print tc.get_task_result(hello_taskid,block=True).ns.word, tc.get_task_result(world_taskid,block=True).ns.word