diff --git a/beets/util/pipeline.py b/beets/util/pipeline.py
index d338cb51b..f4cc23819 100644
--- a/beets/util/pipeline.py
+++ b/beets/util/pipeline.py
@@ -75,8 +75,8 @@ def _invalidate_queue(q, val=None, sync=True):
         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: