From e7782cc36988e9467d7e787aae13050e73ac798f Mon Sep 17 00:00:00 2001 From: Peter B Date: Mon, 11 Apr 2011 12:31:17 -0400 Subject: [PATCH] fixed issue in pipeline when the first coro sends the BUBBLE message --- beets/util/pipeline.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)