def log_stats(self):
        """Output the stats to the LOGGER."""
        if not self.stats.get('counts'):
            if self.consumers:
                LOGGER.info('Did not receive any stats data from children')
            return

        if self.poll_data['processes']:
            LOGGER.warning('%i process(es) did not respond with stats: %r',
                           len(self.poll_data['processes']),
                           self.poll_data['processes'])

        if self.stats['counts']['processes'] > 1:
            LOGGER.info('%i consumers processed %i messages with %i errors',
                        self.stats['counts']['processes'],
                        self.stats['counts']['processed'],
                        self.stats['counts']['failed'])

        for key in self.stats['consumers'].keys():
            LOGGER.info('%i %s %s processed %i messages with %i errors',
                        self.stats['consumers'][key]['processes'], key,
                        self.consumer_keyword(self.stats['consumers'][key]),
                        self.stats['consumers'][key]['processed'],
                        self.stats['consumers'][key]['failed'])
def log_stats ( self ) : if not self . stats . get ( 'counts' ) : if self . consumers : LOGGER . info ( 'Did not receive any stats data from children' ) return if self . poll_data [ 'processes' ] : LOGGER . warning ( '%i process(es) did not respond with stats: %r' , len ( self . poll_data [ 'processes' ] ) , self . poll_data [ 'processes' ] ) if self . stats [ 'counts' ] [ 'processes' ] > 1 : LOGGER . info ( '%i consumers processed %i messages with %i errors' , self . stats [ 'counts' ] [ 'processes' ] , self . stats [ 'counts' ] [ 'processed' ] , self . stats [ 'counts' ] [ 'failed' ] ) for key in self . stats [ 'consumers' ] . keys ( ) : LOGGER . info ( '%i %s %s processed %i messages with %i errors' , self . stats [ 'consumers' ] [ key ] [ 'processes' ] , key , self . consumer_keyword ( self . stats [ 'consumers' ] [ key ] ) , self . stats [ 'consumers' ] [ key ] [ 'processed' ] , self . stats [ 'consumers' ] [ key ] [ 'failed' ] )
Output the stats to the LOGGER.