environment/lib/python2.7/site-packages/IPython/parallel/apps/launcher.py
def start(self, n):
        """Start engines by profile or profile_dir.
        `n` is ignored, and the `engines` config property is used instead.
        """

        dlist = []
        for host, n in self.engines.iteritems():
            if isinstance(n, (tuple, list)):
                n, args = n
            else:
                args = copy.deepcopy(self.engine_args)

            if '@' in host:
                user,host = host.split('@',1)
            else:
                user=None
            for i in range(n):
                if i > 0:
                    time.sleep(self.delay)
                el = self.launcher_class(work_dir=self.work_dir, config=self.config, log=self.log,
                                        profile_dir=self.profile_dir, cluster_id=self.cluster_id,
                )
                if i > 0:
                    # only send files for the first engine on each host
                    el.to_send = []

                # Copy the engine args over to each engine launcher.
                el.engine_cmd = self.engine_cmd
                el.engine_args = args
                el.on_stop(self._notice_engine_stopped)
                d = el.start(user=user, hostname=host)
                self.launchers[ "%s/%i" % (host,i) ] = el
                dlist.append(d)
        self.notify_start(dlist)
        return dlist
def start(self, n):
        """Start engines by profile or profile_dir.
        `n` is ignored, and the `engines` config property is used instead.
        """

        dlist = []
        for host, n in self.engines.iteritems():
            if isinstance(n, (tuple, list)):
                n, args = n
            else:
                args = copy.deepcopy(self.engine_args)

            if '@' in host:
                user,host = host.split('@',1)
            else:
                user=None
            for i in range(n):
                if i > 0:
                    time.sleep(self.delay)
                el = self.launcher_class(work_dir=self.work_dir, config=self.config, log=self.log,
                                        profile_dir=self.profile_dir, cluster_id=self.cluster_id,
                )
                if i > 0:
                    # only send files for the first engine on each host
                    el.to_send = []

                # Copy the engine args over to each engine launcher.
                el.engine_cmd = self.engine_cmd
                el.engine_args = args
                el.on_stop(self._notice_engine_stopped)
                d = el.start(user=user, hostname=host)
                self.launchers[ "%s/%i" % (host,i) ] = el
                dlist.append(d)
        self.notify_start(dlist)
        return dlist
def start ( self , n ) : dlist = [ ] for host , n in self . engines . iteritems ( ) : if isinstance ( n , ( tuple , list ) ) : n , args = n else : args = copy . deepcopy ( self . engine_args ) if '@' in host : user , host = host . split ( '@' , 1 ) else : user = None for i in range ( n ) : if i > 0 : time . sleep ( self . delay ) el = self . launcher_class ( work_dir = self . work_dir , config = self . config , log = self . log , profile_dir = self . profile_dir , cluster_id = self . cluster_id , ) if i > 0 : # only send files for the first engine on each host el . to_send = [ ] # Copy the engine args over to each engine launcher. el . engine_cmd = self . engine_cmd el . engine_args = args el . on_stop ( self . _notice_engine_stopped ) d = el . start ( user = user , hostname = host ) self . launchers [ "%s/%i" % ( host , i ) ] = el dlist . append ( d ) self . notify_start ( dlist ) return dlist
Start engines by profile or profile_dir.
        `n` is ignored, and the `engines` config property is used instead.
Start engines by profile or profile_dir . n is ignored and the engines config property is used instead .