

def flush_events(self):
    events = self.events
    self.events = []
    self.total_count += self.event_count
    self.event_count = 0
    log.debug(('Received %d events since last flush' % len(events)))
    return events

dataset/ETHPy150Open serverdensity/sd-agent/aggregator.py Aggregator.flush_events/original