Method join

petastorm/reader.py:689–691

Joins all worker threads/processes. Will block until all worker workers have been fully terminated.

(self)

        self.stopped = True

    def join(self):
        """Joins all worker threads/processes. Will block until all worker workers have been fully terminated."""
        self._workers_pool.join()

    def cleanup_cache(self):
        if isinstance(self.cache, LocalDiskCache):