diff --git a/lib/music_library/records/batch.ex b/lib/music_library/records/batch.ex
index 0041c56e..4bc5e8f6 100644
--- a/lib/music_library/records/batch.ex
+++ b/lib/music_library/records/batch.ex
@@ -54,7 +54,7 @@ defmodule MusicLibrary.Records.Batch do
 
   defp run_on_all_records(fun) do
     q = from(r in Record)
-    stream = Repo.stream(q)
+    stream = Repo.stream(q, max_rows: 50)
 
     Repo.transaction(
       fn ->