environment/lib/python2.7/site-packages/IPython/parallel/controller/scheduler.py
def handle_result(self, idents, parent, raw_msg, success=True):
        """handle a real task result, either success or failure"""
        # first, relay result to client
        engine = idents[0]
        client = idents[1]
        # swap_ids for ROUTER-ROUTER mirror
        raw_msg[:2] = [client,engine]
        # print (map(str, raw_msg[:4]))
        self.client_stream.send_multipart(raw_msg, copy=False)
        # now, update our data structures
        msg_id = parent['msg_id']
        self.pending[engine].pop(msg_id)
        if success:
            self.completed[engine].add(msg_id)
            self.all_completed.add(msg_id)
        else:
            self.failed[engine].add(msg_id)
            self.all_failed.add(msg_id)
        self.all_done.add(msg_id)
        self.destinations[msg_id] = engine

        self.update_graph(msg_id, success)
def handle_result(self, idents, parent, raw_msg, success=True):
        """handle a real task result, either success or failure"""
        # first, relay result to client
        engine = idents[0]
        client = idents[1]
        # swap_ids for ROUTER-ROUTER mirror
        raw_msg[:2] = [client,engine]
        # print (map(str, raw_msg[:4]))
        self.client_stream.send_multipart(raw_msg, copy=False)
        # now, update our data structures
        msg_id = parent['msg_id']
        self.pending[engine].pop(msg_id)
        if success:
            self.completed[engine].add(msg_id)
            self.all_completed.add(msg_id)
        else:
            self.failed[engine].add(msg_id)
            self.all_failed.add(msg_id)
        self.all_done.add(msg_id)
        self.destinations[msg_id] = engine

        self.update_graph(msg_id, success)
def handle_result ( self , idents , parent , raw_msg , success = True ) : # first, relay result to client engine = idents [ 0 ] client = idents [ 1 ] # swap_ids for ROUTER-ROUTER mirror raw_msg [ : 2 ] = [ client , engine ] # print (map(str, raw_msg[:4])) self . client_stream . send_multipart ( raw_msg , copy = False ) # now, update our data structures msg_id = parent [ 'msg_id' ] self . pending [ engine ] . pop ( msg_id ) if success : self . completed [ engine ] . add ( msg_id ) self . all_completed . add ( msg_id ) else : self . failed [ engine ] . add ( msg_id ) self . all_failed . add ( msg_id ) self . all_done . add ( msg_id ) self . destinations [ msg_id ] = engine self . update_graph ( msg_id , success )
handle a real task result, either success or failure
handle a real task result either success or failure