environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def finish_registration(self, heart):
        """Second half of engine registration, called after our HeartMonitor
        has received a beat from the Engine's Heart."""
        try:
            (eid,queue,reg,purge) = self.incoming_registrations.pop(heart)
        except KeyError:
            self.log.error("registration::tried to finish nonexistant registration", exc_info=True)
            return
        self.log.info("registration::finished registering engine %i:%r", eid, queue)
        if purge is not None:
            purge.stop()
        control = queue
        self.ids.add(eid)
        self.keytable[eid] = queue
        self.engines[eid] = EngineConnector(id=eid, queue=queue, registration=reg,
                                    control=control, heartbeat=heart)
        self.by_ident[queue] = eid
        self.queues[eid] = list()
        self.tasks[eid] = list()
        self.completed[eid] = list()
        self.hearts[heart] = eid
        content = dict(id=eid, queue=self.engines[eid].queue.decode('ascii'))
        if self.notifier:
            self.session.send(self.notifier, "registration_notification", content=content)
        self.log.info("engine::Engine Connected: %i", eid)
def finish_registration(self, heart):
        try:
            (eid,queue,reg,purge) = self.incoming_registrations.pop(heart)
        except KeyError:
            self.log.error("registration::tried to finish nonexistant registration", exc_info=True)
            return
        self.log.info("registration::finished registering engine %i:%r", eid, queue)
        if purge is not None:
            purge.stop()
        control = queue
        self.ids.add(eid)
        self.keytable[eid] = queue
        self.engines[eid] = EngineConnector(id=eid, queue=queue, registration=reg,
                                    control=control, heartbeat=heart)
        self.by_ident[queue] = eid
        self.queues[eid] = list()
        self.tasks[eid] = list()
        self.completed[eid] = list()
        self.hearts[heart] = eid
        content = dict(id=eid, queue=self.engines[eid].queue.decode('ascii'))
        if self.notifier:
            self.session.send(self.notifier, "registration_notification", content=content)
        self.log.info("engine::Engine Connected: %i", eid)
def finish_registration ( self , heart ) : try : ( eid , queue , reg , purge ) = self . incoming_registrations . pop ( heart ) except KeyError : self . log . error ( "registration::tried to finish nonexistant registration" , exc_info = True ) return self . log . info ( "registration::finished registering engine %i:%r" , eid , queue ) if purge is not None : purge . stop ( ) control = queue self . ids . add ( eid ) self . keytable [ eid ] = queue self . engines [ eid ] = EngineConnector ( id = eid , queue = queue , registration = reg , control = control , heartbeat = heart ) self . by_ident [ queue ] = eid self . queues [ eid ] = list ( ) self . tasks [ eid ] = list ( ) self . completed [ eid ] = list ( ) self . hearts [ heart ] = eid content = dict ( id = eid , queue = self . engines [ eid ] . queue . decode ( 'ascii' ) ) if self . notifier : self . session . send ( self . notifier , "registration_notification" , content = content ) self . log . info ( "engine::Engine Connected: %i" , eid )
Second half of engine registration, called after our HeartMonitor
        has received a beat from the Engine's Heart.
Second half of engine registration called after our HeartMonitor has received a beat from the Engine s Heart .