diff -r 670eb4fa1b86 -r 8fb9985382be mercurial/worker.py --- a/mercurial/worker.py Sat May 05 18:41:51 2018 -0700 +++ b/mercurial/worker.py Sat May 05 18:35:16 2018 -0700 @@ -235,7 +235,7 @@ # iteration. if self._interrupted: return - except util.empty: + except pycompat.queue.Empty: break except Exception as e: # store the exception such that the main thread can resurface @@ -262,8 +262,8 @@ return workers = _numworkers(ui) - resultqueue = util.queue() - taskqueue = util.queue() + resultqueue = pycompat.queue.Queue() + taskqueue = pycompat.queue.Queue() # partition work to more pieces than workers to minimize the chance # of uneven distribution of large tasks between the workers for pargs in partition(args, workers * 20):