

def handle_events(self, events, env):
    emsg = ', '.join((('%s: %s' % (event['event_type'], event['message_id'])) for event in events))
    logger.info(('Received %s events: \n%s' % (len(events), emsg)))
    return events

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py LoggingHandler.handle_events/original