environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def _handle_execute_reply(self, msg):
        """Save the reply to an execute_request into our results.

        execute messages are never actually used. apply is used instead.
        """

        parent = msg['parent_header']
        msg_id = parent['msg_id']
        if msg_id not in self.outstanding:
            if msg_id in self.history:
                print ("got stale result: %s"%msg_id)
            else:
                print ("got unknown result: %s"%msg_id)
        else:
            self.outstanding.remove(msg_id)

        content = msg['content']
        header = msg['header']

        # construct metadata:
        md = self.metadata[msg_id]
        md.update(self._extract_metadata(header, parent, content))
        # is this redundant?
        self.metadata[msg_id] = md
        
        e_outstanding = self._outstanding_dict[md['engine_uuid']]
        if msg_id in e_outstanding:
            e_outstanding.remove(msg_id)

        # construct result:
        if content['status'] == 'ok':
            self.results[msg_id] = ExecuteReply(msg_id, content, md)
        elif content['status'] == 'aborted':
            self.results[msg_id] = error.TaskAborted(msg_id)
        elif content['status'] == 'resubmitted':
            # TODO: handle resubmission
            pass
        else:
            self.results[msg_id] = self._unwrap_exception(content)
def _handle_execute_reply(self, msg):
        parent = msg['parent_header']
        msg_id = parent['msg_id']
        if msg_id not in self.outstanding:
            if msg_id in self.history:
                print ("got stale result: %s"%msg_id)
            else:
                print ("got unknown result: %s"%msg_id)
        else:
            self.outstanding.remove(msg_id)

        content = msg['content']
        header = msg['header']

        # construct metadata:
        md = self.metadata[msg_id]
        md.update(self._extract_metadata(header, parent, content))
        # is this redundant?
        self.metadata[msg_id] = md
        
        e_outstanding = self._outstanding_dict[md['engine_uuid']]
        if msg_id in e_outstanding:
            e_outstanding.remove(msg_id)

        # construct result:
        if content['status'] == 'ok':
            self.results[msg_id] = ExecuteReply(msg_id, content, md)
        elif content['status'] == 'aborted':
            self.results[msg_id] = error.TaskAborted(msg_id)
        elif content['status'] == 'resubmitted':
            # TODO: handle resubmission
            pass
        else:
            self.results[msg_id] = self._unwrap_exception(content)
def _handle_execute_reply ( self , msg ) : parent = msg [ 'parent_header' ] msg_id = parent [ 'msg_id' ] if msg_id not in self . outstanding : if msg_id in self . history : print ( "got stale result: %s" % msg_id ) else : print ( "got unknown result: %s" % msg_id ) else : self . outstanding . remove ( msg_id ) content = msg [ 'content' ] header = msg [ 'header' ] # construct metadata: md = self . metadata [ msg_id ] md . update ( self . _extract_metadata ( header , parent , content ) ) # is this redundant? self . metadata [ msg_id ] = md e_outstanding = self . _outstanding_dict [ md [ 'engine_uuid' ] ] if msg_id in e_outstanding : e_outstanding . remove ( msg_id ) # construct result: if content [ 'status' ] == 'ok' : self . results [ msg_id ] = ExecuteReply ( msg_id , content , md ) elif content [ 'status' ] == 'aborted' : self . results [ msg_id ] = error . TaskAborted ( msg_id ) elif content [ 'status' ] == 'resubmitted' : # TODO: handle resubmission pass else : self . results [ msg_id ] = self . _unwrap_exception ( content )
Save the reply to an execute_request into our results.

        execute messages are never actually used. apply is used instead.
Save the reply to an execute_request into our results .