Backup_Repos/beets
1
0
Fork 0
mirror of https://github.com/beetbox/beets.git synced 2026-02-10 17:34:05 +01:00
Code Issues Projects Releases Wiki Activity

fix singleton invocation of pipeline

Browse source
This commit is contained in:
Adrian Sampson 2011-04-17 13:35:00 -07:00
parent 3a5f9ecb38
commit 1b3e7d9310
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
beets/importer.py
View file

@ -356,11 +356,14 @@ def user_query(config):
if choice is action.TRACKS:
# Set up a little pipeline for dealing with the singletons.
item_tasks = []
def emitter():
for item in task.items:
yield ImportTask.item_task(item)
def collector():
while True:
item_task = yield
item_tasks.append(item_task)
ipl = pipeline.Pipeline((iter(task.items), item_lookup(config),
ipl = pipeline.Pipeline((emitter(), item_lookup(config),
item_query(config), collector()))
ipl.run_sequential()
task = pipeline.multiple(item_tasks)