diff options
| author | lain <lain@soykaf.club> | 2020-09-17 13:26:04 +0200 |
|---|---|---|
| committer | lain <lain@soykaf.club> | 2020-09-17 13:26:04 +0200 |
| commit | 7a7385092885bd3c28497828d7b8da12e769ca83 (patch) | |
| tree | beee4c47c210cf4019d44e4c0b9a659c62436fe2 /lib/mix/tasks/pleroma/database.ex | |
| parent | c4061f06ba26656a6a0e61f68c5f097930a4b054 (diff) | |
| parent | c5acbf8a1bd1a14ea82610cb3f69b8ebbb3ea28b (diff) | |
| download | pleroma-7a7385092885bd3c28497828d7b8da12e769ca83.tar.gz | |
Merge branch 'develop' of git.pleroma.social:pleroma/pleroma into alexgleason/pleroma-chat-moderation
Diffstat (limited to 'lib/mix/tasks/pleroma/database.ex')
| -rw-r--r-- | lib/mix/tasks/pleroma/database.ex | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/mix/tasks/pleroma/database.ex b/lib/mix/tasks/pleroma/database.ex index 7f1108dcf..a01c36ece 100644 --- a/lib/mix/tasks/pleroma/database.ex +++ b/lib/mix/tasks/pleroma/database.ex @@ -99,7 +99,7 @@ defmodule Mix.Tasks.Pleroma.Database do where: fragment("(?)->>'likes' is not null", object.data), select: %{id: object.id, likes: fragment("(?)->>'likes'", object.data)} ) - |> Pleroma.RepoStreamer.chunk_stream(100) + |> Pleroma.Repo.chunk_stream(100, :batches) |> Stream.each(fn objects -> ids = objects @@ -145,7 +145,7 @@ defmodule Mix.Tasks.Pleroma.Database do |> where(local: true) |> where([a], fragment("(? ->> 'type'::text) = 'Create'", a.data)) |> where([_a, o], fragment("?->>'type' = 'Note'", o.data)) - |> Pleroma.RepoStreamer.chunk_stream(100) + |> Pleroma.Repo.chunk_stream(100, :batches) |> Stream.each(fn activities -> Enum.each(activities, fn activity -> expires_at = |