environment/lib/python2.7/site-packages/IPython/parallel/controller/scheduler.py
def save_unmet(self, job):
        """Save a message for later submission when its dependencies are met."""
        msg_id = job.msg_id
        self.depending[msg_id] = job
        # track the ids in follow or after, but not those already finished
        for dep_id in job.after.union(job.follow).difference(self.all_done):
            if dep_id not in self.graph:
                self.graph[dep_id] = set()
            self.graph[dep_id].add(msg_id)
def save_unmet(self, job):
        """Save a message for later submission when its dependencies are met."""
        msg_id = job.msg_id
        self.depending[msg_id] = job
        # track the ids in follow or after, but not those already finished
        for dep_id in job.after.union(job.follow).difference(self.all_done):
            if dep_id not in self.graph:
                self.graph[dep_id] = set()
            self.graph[dep_id].add(msg_id)
def save_unmet ( self , job ) : msg_id = job . msg_id self . depending [ msg_id ] = job # track the ids in follow or after, but not those already finished for dep_id in job . after . union ( job . follow ) . difference ( self . all_done ) : if dep_id not in self . graph : self . graph [ dep_id ] = set ( ) self . graph [ dep_id ] . add ( msg_id )
Save a message for later submission when its dependencies are met.
Save a message for later submission when its dependencies are met .