fix coroutine init for "as Tracks" (GC-486)

This commit is contained in:
Adrian Sampson 2013-01-02 16:16:26 -08:00
parent f127d8e18a
commit 9e2e8e5ca7

View file

@ -667,8 +667,8 @@ def user_query(session):
while True:
item_task = yield
item_tasks.append(item_task)
ipl = pipeline.Pipeline((emitter(), item_lookup(),
item_query(), collector()))
ipl = pipeline.Pipeline((emitter(), item_lookup(session),
item_query(session), collector()))
ipl.run_sequential()
task = pipeline.multiple(item_tasks)
continue