environment/lib/python2.7/site-packages/IPython/frontend/html/notebook/clustermanager.py
def start_cluster(self, profile, n=None):
        """Start a cluster for a given profile."""
        self.check_profile(profile)
        data = self.profiles[profile]
        if data['status'] == 'running':
            raise web.HTTPError(409, u'cluster already running')
        cl, esl, default_n = self.build_launchers(data['profile_dir'])
        n = n if n is not None else default_n
        def clean_data():
            data.pop('controller_launcher',None)
            data.pop('engine_set_launcher',None)
            data.pop('n',None)
            data['status'] = 'stopped'
        def engines_stopped(r):
            self.log.debug('Engines stopped')
            if cl.running:
                cl.stop()
            clean_data()
        esl.on_stop(engines_stopped)
        def controller_stopped(r):
            self.log.debug('Controller stopped')
            if esl.running:
                esl.stop()
            clean_data()
        cl.on_stop(controller_stopped)

        dc = ioloop.DelayedCallback(lambda: cl.start(), 0, self.loop)
        dc.start()
        dc = ioloop.DelayedCallback(lambda: esl.start(n), 1000*self.delay, self.loop)
        dc.start()

        self.log.debug('Cluster started')
        data['controller_launcher'] = cl
        data['engine_set_launcher'] = esl
        data['n'] = n
        data['status'] = 'running'
        return self.profile_info(profile)
def start_cluster(self, profile, n=None):
        self.check_profile(profile)
        data = self.profiles[profile]
        if data['status'] == 'running':
            raise web.HTTPError(409, u'cluster already running')
        cl, esl, default_n = self.build_launchers(data['profile_dir'])
        n = n if n is not None else default_n
        def clean_data():
            data.pop('controller_launcher',None)
            data.pop('engine_set_launcher',None)
            data.pop('n',None)
            data['status'] = 'stopped'
        def engines_stopped(r):
            self.log.debug('Engines stopped')
            if cl.running:
                cl.stop()
            clean_data()
        esl.on_stop(engines_stopped)
        def controller_stopped(r):
            self.log.debug('Controller stopped')
            if esl.running:
                esl.stop()
            clean_data()
        cl.on_stop(controller_stopped)

        dc = ioloop.DelayedCallback(lambda: cl.start(), 0, self.loop)
        dc.start()
        dc = ioloop.DelayedCallback(lambda: esl.start(n), 1000*self.delay, self.loop)
        dc.start()

        self.log.debug('Cluster started')
        data['controller_launcher'] = cl
        data['engine_set_launcher'] = esl
        data['n'] = n
        data['status'] = 'running'
        return self.profile_info(profile)
def start_cluster ( self , profile , n = None ) : self . check_profile ( profile ) data = self . profiles [ profile ] if data [ 'status' ] == 'running' : raise web . HTTPError ( 409 , u'cluster already running' ) cl , esl , default_n = self . build_launchers ( data [ 'profile_dir' ] ) n = n if n is not None else default_n def clean_data ( ) : data . pop ( 'controller_launcher' , None ) data . pop ( 'engine_set_launcher' , None ) data . pop ( 'n' , None ) data [ 'status' ] = 'stopped' def engines_stopped ( r ) : self . log . debug ( 'Engines stopped' ) if cl . running : cl . stop ( ) clean_data ( ) esl . on_stop ( engines_stopped ) def controller_stopped ( r ) : self . log . debug ( 'Controller stopped' ) if esl . running : esl . stop ( ) clean_data ( ) cl . on_stop ( controller_stopped ) dc = ioloop . DelayedCallback ( lambda : cl . start ( ) , 0 , self . loop ) dc . start ( ) dc = ioloop . DelayedCallback ( lambda : esl . start ( n ) , 1000 * self . delay , self . loop ) dc . start ( ) self . log . debug ( 'Cluster started' ) data [ 'controller_launcher' ] = cl data [ 'engine_set_launcher' ] = esl data [ 'n' ] = n data [ 'status' ] = 'running' return self . profile_info ( profile )
Start a cluster for a given profile.
Start a cluster for a given profile .