environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def save_iopub_message(self, topics, msg):
        """save an iopub message into the db"""
        # print (topics)
        try:
            msg = self.session.unserialize(msg, content=True)
        except Exception:
            self.log.error("iopub::invalid IOPub message", exc_info=True)
            return

        parent = msg['parent_header']
        if not parent:
            self.log.warn("iopub::IOPub message lacks parent: %r", msg)
            return
        msg_id = parent['msg_id']
        msg_type = msg['header']['msg_type']
        content = msg['content']

        # ensure msg_id is in db
        try:
            rec = self.db.get_record(msg_id)
        except KeyError:
            rec = empty_record()
            rec['msg_id'] = msg_id
            self.db.add_record(msg_id, rec)
        # stream
        d = {}
        if msg_type == 'stream':
            name = content['name']
            s = rec[name] or ''
            d[name] = s + content['data']

        elif msg_type == 'pyerr':
            d['pyerr'] = content
        elif msg_type == 'pyin':
            d['pyin'] = content['code']
        elif msg_type in ('display_data', 'pyout'):
            d[msg_type] = content
        elif msg_type == 'status':
            pass
        else:
            self.log.warn("unhandled iopub msg_type: %r", msg_type)

        if not d:
            return

        try:
            self.db.update_record(msg_id, d)
        except Exception:
            self.log.error("DB Error saving iopub message %r", msg_id, exc_info=True)
def save_iopub_message(self, topics, msg):
        # print (topics)
        try:
            msg = self.session.unserialize(msg, content=True)
        except Exception:
            self.log.error("iopub::invalid IOPub message", exc_info=True)
            return

        parent = msg['parent_header']
        if not parent:
            self.log.warn("iopub::IOPub message lacks parent: %r", msg)
            return
        msg_id = parent['msg_id']
        msg_type = msg['header']['msg_type']
        content = msg['content']

        # ensure msg_id is in db
        try:
            rec = self.db.get_record(msg_id)
        except KeyError:
            rec = empty_record()
            rec['msg_id'] = msg_id
            self.db.add_record(msg_id, rec)
        # stream
        d = {}
        if msg_type == 'stream':
            name = content['name']
            s = rec[name] or ''
            d[name] = s + content['data']

        elif msg_type == 'pyerr':
            d['pyerr'] = content
        elif msg_type == 'pyin':
            d['pyin'] = content['code']
        elif msg_type in ('display_data', 'pyout'):
            d[msg_type] = content
        elif msg_type == 'status':
            pass
        else:
            self.log.warn("unhandled iopub msg_type: %r", msg_type)

        if not d:
            return

        try:
            self.db.update_record(msg_id, d)
        except Exception:
            self.log.error("DB Error saving iopub message %r", msg_id, exc_info=True)
def save_iopub_message ( self , topics , msg ) : # print (topics) try : msg = self . session . unserialize ( msg , content = True ) except Exception : self . log . error ( "iopub::invalid IOPub message" , exc_info = True ) return parent = msg [ 'parent_header' ] if not parent : self . log . warn ( "iopub::IOPub message lacks parent: %r" , msg ) return msg_id = parent [ 'msg_id' ] msg_type = msg [ 'header' ] [ 'msg_type' ] content = msg [ 'content' ] # ensure msg_id is in db try : rec = self . db . get_record ( msg_id ) except KeyError : rec = empty_record ( ) rec [ 'msg_id' ] = msg_id self . db . add_record ( msg_id , rec ) # stream d = { } if msg_type == 'stream' : name = content [ 'name' ] s = rec [ name ] or '' d [ name ] = s + content [ 'data' ] elif msg_type == 'pyerr' : d [ 'pyerr' ] = content elif msg_type == 'pyin' : d [ 'pyin' ] = content [ 'code' ] elif msg_type in ( 'display_data' , 'pyout' ) : d [ msg_type ] = content elif msg_type == 'status' : pass else : self . log . warn ( "unhandled iopub msg_type: %r" , msg_type ) if not d : return try : self . db . update_record ( msg_id , d ) except Exception : self . log . error ( "DB Error saving iopub message %r" , msg_id , exc_info = True )
save an iopub message into the db
save an iopub message into the db