

def metric_removal(self, metric):
    with self._lock:
        category = self.get_category(metric)
        metrics = self._store.get(metrics, {
            
        })
        removed = metrics.pop(metric.metric_name.name, None)
        if (not metrics):
            self._store.pop(category, None)
        return removed

dataset/ETHPy150Open dpkp/kafka-python/kafka/metrics/dict_reporter.py DictReporter.metric_removal/VarMisuse@36/43 `category`->`metrics`