def run(self, epochs=1): for q in self.plugin_queues.values(): heapq.heapify(q) for i in range(1, epochs + 1): self.train() self.call_plugins('epoch', i)