8bd1389b1437ef490da6d9834d90f6f995d17e10,scripts/convert.py,Convert,convert_images,#Convert#,109

Before Change

        while True:
            self.check_thread_error()
            if self.disk_io.completion_event.is_set():
                break
            sleep(1)
        pool.join()

        logger.debug("Putting EOF")

After Change

                completed = completion_queue.get(True, 1)
            except QueueEmpty:
                continue
            completed_count += completed
            logger.debug("Total process pools completed: %s of %s", completed_count, pool.procs)
            if completed_count == pool.procs:
                logger.debug("All processes completed. Joining Pool")
                break
        pool.join()

        logger.debug("Putting EOF")
        save_queue.put("EOF")

Instances