diff options
Diffstat (limited to 'lib/pleroma/repo_streamer.ex')
-rw-r--r-- | lib/pleroma/repo_streamer.ex | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/pleroma/repo_streamer.ex b/lib/pleroma/repo_streamer.ex index cb4d7bb7a..bfa490765 100644 --- a/lib/pleroma/repo_streamer.ex +++ b/lib/pleroma/repo_streamer.ex @@ -6,7 +6,7 @@ defmodule Pleroma.RepoStreamer do alias Pleroma.Repo import Ecto.Query - def chunk_stream(query, chunk_size) do + def chunk_stream(query, chunk_size, opts \\ []) do Stream.unfold(0, fn :halt -> {[], :halt} @@ -16,7 +16,7 @@ defmodule Pleroma.RepoStreamer do |> order_by(asc: :id) |> where([r], r.id > ^last_id) |> limit(^chunk_size) - |> Repo.all() + |> Repo.all(opts) |> case do [] -> {[], :halt} |