

def create_empty_metrics(self, sample_time_by_context, expiry_timestamp, flush_timestamp, metrics):
    for (context, last_sample_time) in sample_time_by_context.items():
        if (last_sample_time < expiry_timestamp):
            log.debug(("%s hasn't been submitted in %ss. Expiring." % (context, self.expiry_seconds)))
            self.last_sample_time_by_context.pop(context, None)
        else:
            metric = Counter(self.formatter, context[0], sample_time_by_context[1], context[2], context[3])
            metrics += metric.flush(flush_timestamp, self.interval)

dataset/ETHPy150Open serverdensity/sd-agent/aggregator.py MetricsBucketAggregator.create_empty_metrics/VarMisuse@88/147 `context`->`sample_time_by_context`