in bowler/tool.py [0:0]
def refactor_queue(self) -> None:
self.semaphore.acquire()
while True:
filename = self.queue.get()
if filename is None:
break
try:
hunks = self.refactor_file(filename)
self.results.put((filename, hunks, None))
except RetryFile:
self.log_debug(f"Retrying {filename} later...")
self.queue.put(filename)
except BowlerException as e:
log.exception(f"Bowler exception during transform of {filename}: {e}")
self.results.put((filename, e.hunks, e))
except Exception as e:
log.exception(f"Skipping {filename}: failed to transform because {e}")
self.results.put((filename, [], e))
finally:
self.queue.task_done()
self.semaphore.release()