diff options
| author | Mark Felder <feld@FreeBSD.org> | 2020-09-23 11:56:22 -0500 |
|---|---|---|
| committer | Mark Felder <feld@FreeBSD.org> | 2020-09-23 11:56:22 -0500 |
| commit | f3a1f9c3bbb7321876a09b3846b5e10ecf4af94f (patch) | |
| tree | bcfd29188a841470cdeca478b1c5a3bbd4cc930a /lib/mix/tasks/pleroma/user.ex | |
| parent | 34d7e864db8f9cc7fb73ce2fef8466ce8e09ed85 (diff) | |
| parent | e02101e15c425416975f756aca7f3b058006668d (diff) | |
| download | pleroma-f3a1f9c3bbb7321876a09b3846b5e10ecf4af94f.tar.gz | |
Merge branch 'develop' into feature/bulk-confirmation
Diffstat (limited to 'lib/mix/tasks/pleroma/user.ex')
| -rw-r--r-- | lib/mix/tasks/pleroma/user.ex | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/mix/tasks/pleroma/user.ex b/lib/mix/tasks/pleroma/user.ex index 4073fe5a4..8196e34b1 100644 --- a/lib/mix/tasks/pleroma/user.ex +++ b/lib/mix/tasks/pleroma/user.ex @@ -179,7 +179,7 @@ defmodule Mix.Tasks.Pleroma.User do start_pleroma() Pleroma.User.Query.build(%{nickname: "@#{instance}"}) - |> Pleroma.RepoStreamer.chunk_stream(500) + |> Pleroma.Repo.chunk_stream(500, :batches) |> Stream.each(fn users -> users |> Enum.each(fn user -> @@ -413,7 +413,7 @@ defmodule Mix.Tasks.Pleroma.User do start_pleroma() Pleroma.User.Query.build(%{local: true}) - |> Pleroma.RepoStreamer.chunk_stream(500) + |> Pleroma.Repo.chunk_stream(500, :batches) |> Stream.each(fn users -> users |> Enum.each(fn user -> |