upstream/ipython Files · docs/examples/parallel/task2.py

new completer for qtconsole....

new completer for qtconsole. add a completer to the qtconsole that is navigable by arraow keys and tab. One need to call it twice to get it on focus and be able to select completion with Return. looks like zsh completer, not the gui drop down list of --gui-completer. This also try to split the completion logic from console_widget, and try to keep the old completer qui around. The plain completer that never takes focus back, and the QlistWidget completer. to switch between the 3, the --gui-completion flag as been changed to take an argument (plain, droplist, ncurses).

Thomas Kluyver - - Load All Authors

File last commit:

r6455:15863dc1


                r7389:1422d277

Download file

             task2.py
        
                    50 lines
            
             | 924 B
            
                | text/x-python
            
             |
                PythonLexer
            
             / docs / examples / parallel / task2.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      #!/usr/bin/env python

      # encoding: utf-8

      from IPython.parallel import Client

      import time

      import sys

      flush = sys.stdout.flush

      rc = Client()

      v = rc.load_balanced_view()

      mux = rc[:]

      for i in range(24):

          v.apply(time.sleep, 1)

      for i in range(6):

          time.sleep(1.0)

          print("Queue status (vebose=False)")

          print(v.queue_status(verbose=False))

          flush()

      for i in range(24):

          v.apply(time.sleep, 1)

      for i in range(6):

          time.sleep(1.0)

          print("Queue status (vebose=True)")

          print(v.queue_status(verbose=True))

          flush()

      for i in range(12):

          v.apply(time.sleep, 2)

      print("Queue status (vebose=True)")

      print(v.queue_status(verbose=True))

      flush()

      # qs = v.queue_status(verbose=True)

      # queued = qs['scheduled']

      for msg_id in v.history[-4:]:

          v.abort(msg_id)

      for i in range(6):

          time.sleep(1.0)

          print("Queue status (vebose=True)")

          print(v.queue_status(verbose=True))

          flush()

	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

				from IPython.parallel import Client
				import time
				import sys
				flush = sys.stdout.flush

				rc = Client()
				v = rc.load_balanced_view()
				mux = rc[:]


				for i in range(24):
				v.apply(time.sleep, 1)

				for i in range(6):
				time.sleep(1.0)
				print("Queue status (vebose=False)")
				print(v.queue_status(verbose=False))
				flush()

				for i in range(24):
				v.apply(time.sleep, 1)

				for i in range(6):
				time.sleep(1.0)
				print("Queue status (vebose=True)")
				print(v.queue_status(verbose=True))
				flush()

				for i in range(12):
				v.apply(time.sleep, 2)

				print("Queue status (vebose=True)")
				print(v.queue_status(verbose=True))
				flush()

				# qs = v.queue_status(verbose=True)
				# queued = qs['scheduled']

				for msg_id in v.history[-4:]:
				v.abort(msg_id)

				for i in range(6):
				time.sleep(1.0)
				print("Queue status (vebose=True)")
				print(v.queue_status(verbose=True))
				flush()