diff --git a/beets/importer.py b/beets/importer.py
index a39ff82f3..651e218ca 100644
--- a/beets/importer.py
+++ b/beets/importer.py
@@ -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