diff --git a/beets/util/pipeline.py b/beets/util/pipeline.py index 512276afe..5aaf26f2b 100644 --- a/beets/util/pipeline.py +++ b/beets/util/pipeline.py @@ -99,10 +99,10 @@ class FirstPipelineThread(PipelineThread): return # Send it to the next stage. - self.out_queue.put(msg) if msg is BUBBLE: continue - + self.out_queue.put(msg) + # Generator finished; shut down the pipeline. self.out_queue.put(POISON)