upstream/ipython Files · IPython/parallel/__init__.py

add parent to Configurable...

add parent to Configurable this adds the notion of a parent and member config, so the config: c.Foo.Bar.attr = value will only set `Bar.attr = value` for `Bar` instances which are members of `Foo` instances. The mechanism for doing this is ```python f = Foo(config=cfg) f.b = Bar(parent=f) ``` This Instance config has higher priority than plain class config for Bar, but still lower priority than direct keyword arg trait assignment. The main implication this has is to change the standard creation of descendants: ```python self.bar = Bar(config=self.config) ``` into a direct parent expression ```python self.bar = Bar(parent=self) ``` This also means that most Configurables will actually have a handle on their parent object.

MinRK - - Load All Authors

File last commit:

r10201:06a54042


                r11062:7f44a560

Download file

             __init__.py
        
                    72 lines
            
             | 2.1 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / IPython / parallel / __init__.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      """The IPython ZMQ-based parallel computing interface.

      Authors:

      * MinRK

      """

      #-----------------------------------------------------------------------------

      #  Copyright (C) 2011 The IPython Development Team

      #

      #  Distributed under the terms of the BSD License.  The full license is in

      #  the file COPYING, distributed as part of this software.

      #-----------------------------------------------------------------------------

      #-----------------------------------------------------------------------------

      # Imports

      #-----------------------------------------------------------------------------

      import os

      import warnings

      import zmq

      from IPython.config.configurable import MultipleInstanceError

      from IPython.utils.zmqrelated import check_for_zmq

      min_pyzmq = '2.1.11'

      check_for_zmq(min_pyzmq, 'IPython.parallel')

      from IPython.utils.pickleutil import Reference

      from .client.asyncresult import *

      from .client.client import Client

      from .client.remotefunction import *

      from .client.view import *

      from .controller.dependency import *

      from .error import *

      from .util import interactive

      #-----------------------------------------------------------------------------

      # Functions

      #-----------------------------------------------------------------------------

      def bind_kernel(**kwargs):

          """Bind an Engine's Kernel to be used as a full IPython kernel.

          This allows a running Engine to be used simultaneously as a full IPython kernel

          with the QtConsole or other frontends.

          This function returns immediately.

          """

          from IPython.kernel.zmq.kernelapp import IPKernelApp

          from IPython.parallel.apps.ipengineapp import IPEngineApp

          # first check for IPKernelApp, in which case this should be a no-op

          # because there is already a bound kernel

          if IPKernelApp.initialized() and isinstance(IPKernelApp._instance, IPKernelApp):

              return

          if IPEngineApp.initialized():

              try:

                  app = IPEngineApp.instance()

              except MultipleInstanceError:

                  pass

              else:

                  return app.bind_kernel(**kwargs)

          raise RuntimeError("bind_kernel be called from an IPEngineApp instance")

	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

				"""The IPython ZMQ-based parallel computing interface.

				Authors:

				* MinRK
				"""
				#-----------------------------------------------------------------------------
				# Copyright (C) 2011 The IPython Development Team
				#
				# Distributed under the terms of the BSD License. The full license is in
				# the file COPYING, distributed as part of this software.
				#-----------------------------------------------------------------------------

				#-----------------------------------------------------------------------------
				# Imports
				#-----------------------------------------------------------------------------

				import os
				import warnings

				import zmq

				from IPython.config.configurable import MultipleInstanceError
				from IPython.utils.zmqrelated import check_for_zmq

				min_pyzmq = '2.1.11'

				check_for_zmq(min_pyzmq, 'IPython.parallel')

				from IPython.utils.pickleutil import Reference

				from .client.asyncresult import *
				from .client.client import Client
				from .client.remotefunction import *
				from .client.view import *
				from .controller.dependency import *
				from .error import *
				from .util import interactive

				#-----------------------------------------------------------------------------
				# Functions
				#-----------------------------------------------------------------------------


				def bind_kernel(**kwargs):
				"""Bind an Engine's Kernel to be used as a full IPython kernel.

				This allows a running Engine to be used simultaneously as a full IPython kernel
				with the QtConsole or other frontends.

				This function returns immediately.
				"""
				from IPython.kernel.zmq.kernelapp import IPKernelApp
				from IPython.parallel.apps.ipengineapp import IPEngineApp

				# first check for IPKernelApp, in which case this should be a no-op
				# because there is already a bound kernel
				if IPKernelApp.initialized() and isinstance(IPKernelApp._instance, IPKernelApp):
				return

				if IPEngineApp.initialized():
				try:
				app = IPEngineApp.instance()
				except MultipleInstanceError:
				pass
				else:
				return app.bind_kernel(**kwargs)

				raise RuntimeError("bind_kernel be called from an IPEngineApp instance")