def reset(self):
        """
        Initialize all workers for a new decomposition.
        """
        for workerid, worker in self.workers.iteritems():
            logger.info("resetting worker %s" % workerid)
            worker.reset()
            worker.requestjob()
        self._jobsdone = 0
        self._jobsreceived = 0
dataset/ETHPy150Open largelymfs/topical_word_embeddings/TWE-1/gensim/models/lsi_dispatcher.py/Dispatcher.reset/original