environment/lib/python2.7/site-packages/IPython/parallel/apps/logwatcher.py
def log_message(self, raw):
        """receive and parse a message, then log it."""
        if len(raw) != 2 or '.' not in raw[0]:
            self.log.error("Invalid log message: %s"%raw)
            return
        else:
            topic, msg = raw
            # don't newline, since log messages always newline:
            topic,level_name = topic.rsplit('.',1)
            level,topic = self._extract_level(topic)
            if msg[-1] == '\n':
                msg = msg[:-1]
            self.log.log(level, "[%s] %s" % (topic, msg))
def log_message(self, raw):
        """receive and parse a message, then log it."""
        if len(raw) != 2 or '.' not in raw[0]:
            self.log.error("Invalid log message: %s"%raw)
            return
        else:
            topic, msg = raw
            # don't newline, since log messages always newline:
            topic,level_name = topic.rsplit('.',1)
            level,topic = self._extract_level(topic)
            if msg[-1] == '\n':
                msg = msg[:-1]
            self.log.log(level, "[%s] %s" % (topic, msg))
def log_message ( self , raw ) : if len ( raw ) != 2 or '.' not in raw [ 0 ] : self . log . error ( "Invalid log message: %s" % raw ) return else : topic , msg = raw # don't newline, since log messages always newline: topic , level_name = topic . rsplit ( '.' , 1 ) level , topic = self . _extract_level ( topic ) if msg [ - 1 ] == '\n' : msg = msg [ : - 1 ] self . log . log ( level , "[%s] %s" % ( topic , msg ) )
receive and parse a message, then log it.
receive and parse a message then log it .