

def flush(self, timestamp, interval):
    if (len(self.samples) < 2):
        return []
    try:
        try:
            val = self._rate(self.samples[(- 2)], self.samples[(- 1)])
        except Exception:
            return []
        return [self.formatter(hostname=self.hostname, device_name=self.device_name, tags=self.tags, metric=self.name, value=val, timestamp=timestamp, metric_type=MetricTypes.GAUGE, interval=interval)]
    finally:
        self.samples = self.samples[(- 1):]

dataset/ETHPy150Open serverdensity/sd-agent/aggregator.py Rate.flush/original