projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'features/validators-video' into 'develop'
[akkoma]
/
lib
/
mix
/
tasks
/
pleroma
/
user.ex
diff --git
a/lib/mix/tasks/pleroma/user.ex
b/lib/mix/tasks/pleroma/user.ex
index 01824aa18b0f45dda65716d6189856f3394f63c1..b20c49d89538db746214e7b6b17256995d3879c8 100644
(file)
--- 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}"})
start_pleroma()
Pleroma.User.Query.build(%{nickname: "@#{instance}"})
- |> Pleroma.Repo
Streamer.chunk_stream(500
)
+ |> Pleroma.Repo
.chunk_stream(500, :batches
)
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->
@@
-370,7
+370,7
@@
defmodule Mix.Tasks.Pleroma.User do
start_pleroma()
Pleroma.User.Query.build(%{local: true})
start_pleroma()
Pleroma.User.Query.build(%{local: true})
- |> Pleroma.Repo
Streamer.chunk_stream(500
)
+ |> Pleroma.Repo
.chunk_stream(500, :batches
)
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->