Stream 50 rows at a time for batch operations
This commit is contained in:
@@ -54,7 +54,7 @@ defmodule MusicLibrary.Records.Batch do
|
|||||||
|
|
||||||
defp run_on_all_records(fun) do
|
defp run_on_all_records(fun) do
|
||||||
q = from(r in Record)
|
q = from(r in Record)
|
||||||
stream = Repo.stream(q)
|
stream = Repo.stream(q, max_rows: 50)
|
||||||
|
|
||||||
Repo.transaction(
|
Repo.transaction(
|
||||||
fn ->
|
fn ->
|
||||||
|
|||||||
Reference in New Issue
Block a user