def process(self, tiles, progress):
    if (not self.dry_run):
        while True:
            try:
                self.tiles_queue.put(tiles, timeout=5)
            except Queue.Full:
                alive = False
                for proc in self.procs:
                    if proc.is_alive():
                        alive = True
                        break
                if (not alive):
                    log.warn('no workers left, stopping')
                    raise SeedInterrupted
                continue
            else:
                break
        if self.progress_logger:
            self.progress_logger.log_step(progress)
def process(self, tiles, progress):
    if (not self.dry_run):
        while True:
            try:
                self.tiles_queue.put(tiles, timeout=5)
            except Queue.Full:
                alive = False
                for proc in self.procs:
                    if proc.is_alive():
                        alive = True
                        break
                if (not alive):
                    log.warn('no workers left, stopping')
                    raise SeedInterrupted
                continue
            else:
                break
        if self.progress_logger:
            self.progress_logger.log_step(progress)