diff options
author | lain <lain@soykaf.club> | 2020-12-16 11:35:45 +0000 |
---|---|---|
committer | lain <lain@soykaf.club> | 2020-12-16 11:35:45 +0000 |
commit | 8b8c317c0ff1534d3296369ba315b8919e8dc55c (patch) | |
tree | a5de91eecea4b6cd62a96d800ed714e50c649959 /lib/mix/tasks/pleroma | |
parent | 6bb4f4e1721d30762978b59a1aed11137223c183 (diff) | |
parent | c37f78d1c87b0554b29213ab77f484747fa48f88 (diff) | |
download | pleroma-8b8c317c0ff1534d3296369ba315b8919e8dc55c.tar.gz |
Merge branch 'fix/2336-mastoapi-ws-posts-dropping' into 'develop'
Fix mastoapi ws posts dropping
Closes #2336
See merge request pleroma/pleroma!3198
Diffstat (limited to 'lib/mix/tasks/pleroma')
-rw-r--r-- | lib/mix/tasks/pleroma/database.ex | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/lib/mix/tasks/pleroma/database.ex b/lib/mix/tasks/pleroma/database.ex index a01c36ece..22151ce08 100644 --- a/lib/mix/tasks/pleroma/database.ex +++ b/lib/mix/tasks/pleroma/database.ex @@ -48,9 +48,15 @@ defmodule Mix.Tasks.Pleroma.Database do def run(["update_users_following_followers_counts"]) do start_pleroma() - User - |> Repo.all() - |> Enum.each(&User.update_follower_count/1) + Repo.transaction( + fn -> + from(u in User, select: u) + |> Repo.stream() + |> Stream.each(&User.update_follower_count/1) + |> Stream.run() + end, + timeout: :infinity + ) end def run(["prune_objects" | args]) do |