environment/lib/python2.7/site-packages/IPython/parallel/controller/scheduler.py
def handle_unmet_dependency(self, idents, parent):
        """handle an unmet dependency"""
        engine = idents[0]
        msg_id = parent['msg_id']

        job = self.pending[engine].pop(msg_id)
        job.blacklist.add(engine)

        if job.blacklist == job.targets:
            self.depending[msg_id] = job
            self.fail_unreachable(msg_id)
        elif not self.maybe_run(job):
            # resubmit failed
            if msg_id not in self.all_failed:
                # put it back in our dependency tree
                self.save_unmet(job)

        if self.hwm:
            try:
                idx = self.targets.index(engine)
            except ValueError:
                pass # skip load-update for dead engines
            else:
                if self.loads[idx] == self.hwm-1:
                    self.update_graph(None)
def handle_unmet_dependency(self, idents, parent):
        engine = idents[0]
        msg_id = parent['msg_id']

        job = self.pending[engine].pop(msg_id)
        job.blacklist.add(engine)

        if job.blacklist == job.targets:
            self.depending[msg_id] = job
            self.fail_unreachable(msg_id)
        elif not self.maybe_run(job):
            # resubmit failed
            if msg_id not in self.all_failed:
                # put it back in our dependency tree
                self.save_unmet(job)

        if self.hwm:
            try:
                idx = self.targets.index(engine)
            except ValueError:
                pass # skip load-update for dead engines
            else:
                if self.loads[idx] == self.hwm-1:
                    self.update_graph(None)
def handle_unmet_dependency ( self , idents , parent ) : engine = idents [ 0 ] msg_id = parent [ 'msg_id' ] job = self . pending [ engine ] . pop ( msg_id ) job . blacklist . add ( engine ) if job . blacklist == job . targets : self . depending [ msg_id ] = job self . fail_unreachable ( msg_id ) elif not self . maybe_run ( job ) : # resubmit failed if msg_id not in self . all_failed : # put it back in our dependency tree self . save_unmet ( job ) if self . hwm : try : idx = self . targets . index ( engine ) except ValueError : pass # skip load-update for dead engines else : if self . loads [ idx ] == self . hwm - 1 : self . update_graph ( None )
handle an unmet dependency
handle an unmet dependency