upstream/ipython Files · IPython/kernel/tests/test_contexts.py

Initial refactor of task dependency system....

Initial refactor of task dependency system. We are thinking about refactoring the task dependency system. Currently is is based on engine properties and a function sent with each task. In this commit, I have added a TaskRejectError that tasks can raise to indicate that the engine doesn't have the required dependencies. For now I have not removed any of the old stuff, but I have added warnings that we might remove the older *_prop* methods in IMultiEngine. See this ticket for more info: https://bugs.launchpad.net/bugs/361419

Fernando Perez - - Load All Authors

File last commit:

r1706:a953d91d


                r1952:d68cab7f

Download file

             test_contexts.py
        
                    43 lines
            
             | 1.0 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / IPython / kernel / tests / test_contexts.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      #from __future__ import with_statement

      # XXX This file is currently disabled to preserve 2.4 compatibility.

      #def test_simple():

      if 0:

          # XXX - for now, we need a running cluster to be started separately.  The

          # daemon work is almost finished, and will make much of this unnecessary.

          from IPython.kernel import client

          mec = client.MultiEngineClient(('127.0.0.1',10105))

          try:

              mec.get_ids()

          except ConnectionRefusedError:

              import os, time

              os.system('ipcluster -n 2 &')

              time.sleep(2)

              mec = client.MultiEngineClient(('127.0.0.1',10105))

          mec.block = False

          import itertools

          c = itertools.count()

          parallel = RemoteMultiEngine(mec)

          mec.pushAll()

          ## with parallel as pr:

          ##     # A comment

          ##     remote()  # this means the code below only runs remotely

          ##     print 'Hello remote world'

          ##     x = range(10)

          ##     # Comments are OK

          ##     # Even misindented.

          ##     y = x+1

          ## with pfor('i',sequence) as pr:

          ##     print x[i]

          print pr.x + pr.y

	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

				#from __future__ import with_statement

				# XXX This file is currently disabled to preserve 2.4 compatibility.

				#def test_simple():
				if 0:

				# XXX - for now, we need a running cluster to be started separately. The
				# daemon work is almost finished, and will make much of this unnecessary.
				from IPython.kernel import client
				mec = client.MultiEngineClient(('127.0.0.1',10105))

				try:
				mec.get_ids()
				except ConnectionRefusedError:
				import os, time
				os.system('ipcluster -n 2 &')
				time.sleep(2)
				mec = client.MultiEngineClient(('127.0.0.1',10105))

				mec.block = False

				import itertools
				c = itertools.count()

				parallel = RemoteMultiEngine(mec)

				mec.pushAll()

				## with parallel as pr:
				## # A comment
				## remote() # this means the code below only runs remotely
				## print 'Hello remote world'
				## x = range(10)
				## # Comments are OK
				## # Even misindented.
				## y = x+1


				## with pfor('i',sequence) as pr:
				## print x[i]

				print pr.x + pr.y