environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def shutdown(self, targets='all', restart=False, hub=False, block=None):
        """Terminates one or more engine processes, optionally including the hub.
        
        Parameters
        ----------
        
        targets: list of ints or 'all' [default: all]
            Which engines to shutdown.
        hub: bool [default: False]
            Whether to include the Hub.  hub=True implies targets='all'.
        block: bool [default: self.block]
            Whether to wait for clean shutdown replies or not.
        restart: bool [default: False]
            NOT IMPLEMENTED
            whether to restart engines after shutting them down.
        """
        
        if restart:
            raise NotImplementedError("Engine restart is not yet implemented")
        
        block = self.block if block is None else block
        if hub:
            targets = 'all'
        targets = self._build_targets(targets)[0]
        for t in targets:
            self.session.send(self._control_socket, 'shutdown_request',
                        content={'restart':restart},ident=t)
        error = False
        if block or hub:
            self._flush_ignored_control()
            for i in range(len(targets)):
                idents,msg = self.session.recv(self._control_socket, 0)
                if self.debug:
                    pprint(msg)
                if msg['content']['status'] != 'ok':
                    error = self._unwrap_exception(msg['content'])
        else:
            self._ignored_control_replies += len(targets)

        if hub:
            time.sleep(0.25)
            self.session.send(self._query_socket, 'shutdown_request')
            idents,msg = self.session.recv(self._query_socket, 0)
            if self.debug:
                pprint(msg)
            if msg['content']['status'] != 'ok':
                error = self._unwrap_exception(msg['content'])

        if error:
            raise error
def shutdown(self, targets='all', restart=False, hub=False, block=None):
        """Terminates one or more engine processes, optionally including the hub.
        
        Parameters
        ----------
        
        targets: list of ints or 'all' [default: all]
            Which engines to shutdown.
        hub: bool [default: False]
            Whether to include the Hub.  hub=True implies targets='all'.
        block: bool [default: self.block]
            Whether to wait for clean shutdown replies or not.
        restart: bool [default: False]
            NOT IMPLEMENTED
            whether to restart engines after shutting them down.
        """
        
        if restart:
            raise NotImplementedError("Engine restart is not yet implemented")
        
        block = self.block if block is None else block
        if hub:
            targets = 'all'
        targets = self._build_targets(targets)[0]
        for t in targets:
            self.session.send(self._control_socket, 'shutdown_request',
                        content={'restart':restart},ident=t)
        error = False
        if block or hub:
            self._flush_ignored_control()
            for i in range(len(targets)):
                idents,msg = self.session.recv(self._control_socket, 0)
                if self.debug:
                    pprint(msg)
                if msg['content']['status'] != 'ok':
                    error = self._unwrap_exception(msg['content'])
        else:
            self._ignored_control_replies += len(targets)

        if hub:
            time.sleep(0.25)
            self.session.send(self._query_socket, 'shutdown_request')
            idents,msg = self.session.recv(self._query_socket, 0)
            if self.debug:
                pprint(msg)
            if msg['content']['status'] != 'ok':
                error = self._unwrap_exception(msg['content'])

        if error:
            raise error
def shutdown ( self , targets = 'all' , restart = False , hub = False , block = None ) : if restart : raise NotImplementedError ( "Engine restart is not yet implemented" ) block = self . block if block is None else block if hub : targets = 'all' targets = self . _build_targets ( targets ) [ 0 ] for t in targets : self . session . send ( self . _control_socket , 'shutdown_request' , content = { 'restart' : restart } , ident = t ) error = False if block or hub : self . _flush_ignored_control ( ) for i in range ( len ( targets ) ) : idents , msg = self . session . recv ( self . _control_socket , 0 ) if self . debug : pprint ( msg ) if msg [ 'content' ] [ 'status' ] != 'ok' : error = self . _unwrap_exception ( msg [ 'content' ] ) else : self . _ignored_control_replies += len ( targets ) if hub : time . sleep ( 0.25 ) self . session . send ( self . _query_socket , 'shutdown_request' ) idents , msg = self . session . recv ( self . _query_socket , 0 ) if self . debug : pprint ( msg ) if msg [ 'content' ] [ 'status' ] != 'ok' : error = self . _unwrap_exception ( msg [ 'content' ] ) if error : raise error
Terminates one or more engine processes, optionally including the hub.
        
        Parameters
        ----------
        
        targets: list of ints or 'all' [default: all]
            Which engines to shutdown.
        hub: bool [default: False]
            Whether to include the Hub.  hub=True implies targets='all'.
        block: bool [default: self.block]
            Whether to wait for clean shutdown replies or not.
        restart: bool [default: False]
            NOT IMPLEMENTED
            whether to restart engines after shutting them down.
Terminates one or more engine processes optionally including the hub . Parameters ---------- targets : list of ints or all [ default : all ] Which engines to shutdown . hub : bool [ default : False ] Whether to include the Hub . hub = True implies targets = all . block : bool [ default : self . block ] Whether to wait for clean shutdown replies or not . restart : bool [ default : False ] NOT IMPLEMENTED whether to restart engines after shutting them down .