environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def save_task_request(self, idents, msg):
        """Save the submission of a task."""
        client_id = idents[0]

        try:
            msg = self.session.unserialize(msg)
        except Exception:
            self.log.error("task::client %r sent invalid task message: %r",
                    client_id, msg, exc_info=True)
            return
        record = init_record(msg)

        record['client_uuid'] = client_id.decode('ascii')
        record['queue'] = 'task'
        header = msg['header']
        msg_id = header['msg_id']
        self.pending.add(msg_id)
        self.unassigned.add(msg_id)
        try:
            # it's posible iopub arrived first:
            existing = self.db.get_record(msg_id)
            if existing['resubmitted']:
                for key in ('submitted', 'client_uuid', 'buffers'):
                    # don't clobber these keys on resubmit
                    # submitted and client_uuid should be different
                    # and buffers might be big, and shouldn't have changed
                    record.pop(key)
                    # still check content,header which should not change
                    # but are not expensive to compare as buffers

            for key,evalue in existing.iteritems():
                if key.endswith('buffers'):
                    # don't compare buffers
                    continue
                rvalue = record.get(key, None)
                if evalue and rvalue and evalue != rvalue:
                    self.log.warn("conflicting initial state for record: %r:%r <%r> %r", msg_id, rvalue, key, evalue)
                elif evalue and not rvalue:
                    record[key] = evalue
            try:
                self.db.update_record(msg_id, record)
            except Exception:
                self.log.error("DB Error updating record %r", msg_id, exc_info=True)
        except KeyError:
            try:
                self.db.add_record(msg_id, record)
            except Exception:
                self.log.error("DB Error adding record %r", msg_id, exc_info=True)
        except Exception:
            self.log.error("DB Error saving task request %r", msg_id, exc_info=True)
def save_task_request(self, idents, msg):
        client_id = idents[0]

        try:
            msg = self.session.unserialize(msg)
        except Exception:
            self.log.error("task::client %r sent invalid task message: %r",
                    client_id, msg, exc_info=True)
            return
        record = init_record(msg)

        record['client_uuid'] = client_id.decode('ascii')
        record['queue'] = 'task'
        header = msg['header']
        msg_id = header['msg_id']
        self.pending.add(msg_id)
        self.unassigned.add(msg_id)
        try:
            # it's posible iopub arrived first:
            existing = self.db.get_record(msg_id)
            if existing['resubmitted']:
                for key in ('submitted', 'client_uuid', 'buffers'):
                    # don't clobber these keys on resubmit
                    # submitted and client_uuid should be different
                    # and buffers might be big, and shouldn't have changed
                    record.pop(key)
                    # still check content,header which should not change
                    # but are not expensive to compare as buffers

            for key,evalue in existing.iteritems():
                if key.endswith('buffers'):
                    # don't compare buffers
                    continue
                rvalue = record.get(key, None)
                if evalue and rvalue and evalue != rvalue:
                    self.log.warn("conflicting initial state for record: %r:%r <%r> %r", msg_id, rvalue, key, evalue)
                elif evalue and not rvalue:
                    record[key] = evalue
            try:
                self.db.update_record(msg_id, record)
            except Exception:
                self.log.error("DB Error updating record %r", msg_id, exc_info=True)
        except KeyError:
            try:
                self.db.add_record(msg_id, record)
            except Exception:
                self.log.error("DB Error adding record %r", msg_id, exc_info=True)
        except Exception:
            self.log.error("DB Error saving task request %r", msg_id, exc_info=True)
def save_task_request ( self , idents , msg ) : client_id = idents [ 0 ] try : msg = self . session . unserialize ( msg ) except Exception : self . log . error ( "task::client %r sent invalid task message: %r" , client_id , msg , exc_info = True ) return record = init_record ( msg ) record [ 'client_uuid' ] = client_id . decode ( 'ascii' ) record [ 'queue' ] = 'task' header = msg [ 'header' ] msg_id = header [ 'msg_id' ] self . pending . add ( msg_id ) self . unassigned . add ( msg_id ) try : # it's posible iopub arrived first: existing = self . db . get_record ( msg_id ) if existing [ 'resubmitted' ] : for key in ( 'submitted' , 'client_uuid' , 'buffers' ) : # don't clobber these keys on resubmit # submitted and client_uuid should be different # and buffers might be big, and shouldn't have changed record . pop ( key ) # still check content,header which should not change # but are not expensive to compare as buffers for key , evalue in existing . iteritems ( ) : if key . endswith ( 'buffers' ) : # don't compare buffers continue rvalue = record . get ( key , None ) if evalue and rvalue and evalue != rvalue : self . log . warn ( "conflicting initial state for record: %r:%r <%r> %r" , msg_id , rvalue , key , evalue ) elif evalue and not rvalue : record [ key ] = evalue try : self . db . update_record ( msg_id , record ) except Exception : self . log . error ( "DB Error updating record %r" , msg_id , exc_info = True ) except KeyError : try : self . db . add_record ( msg_id , record ) except Exception : self . log . error ( "DB Error adding record %r" , msg_id , exc_info = True ) except Exception : self . log . error ( "DB Error saving task request %r" , msg_id , exc_info = True )
Save the submission of a task.
Save the submission of a task .