diff --git a/beets/util/pipeline.py b/beets/util/pipeline.py
index d338cb51b5..f4cc238193 100644
--- a/beets/util/pipeline.py
+++ b/beets/util/pipeline.py
@@ -75,8 +75,8 @@ def _get():
         q._qsize = _qsize
         q._put = _put
         q._get = _get
-        q.not_empty.notifyAll()
-        q.not_full.notifyAll()
+        q.not_empty.notify_all()
+        q.not_full.notify_all()
 
     finally:
         if sync: