

def handle_events(self, events, env):
    for event in events:
        event_type = event['event_type']
        if events.match_type(event_type):
            self.events.append(event)
    logger.debug(('Matched %s events.' % len(self.events)))
    return events

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py AtomPubHandler.handle_events/VarMisuse@29/38 `self`->`events`